Author: ningjiang
Date: Sun Aug 24 20:54:47 2008
New Revision: 688611
URL: http://svn.apache.org/viewvc?rev=688611&view=rev
Log:
CAMEL-846 clean up the codes
Modified:
activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java
activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelTargetAdapter.java
Modified:
activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java?rev=688611&r1=688610&r2=688611&view=diff
==============================================================================
---
activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java
(original)
+++
activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java
Sun Aug 24 20:54:47 2008
@@ -93,8 +93,7 @@
outputChannel.send(siOutmessage);
if (exchange.getPattern().isInCapable()) {
- org.springframework.integration.message.Message siInMessage =
- inputChannel.receive();
+ org.springframework.integration.message.Message siInMessage =
inputChannel.receive();
SpringIntegrationBinding.storeToCamelMessage(siInMessage,
exchange.getOut());
}
Modified:
activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelTargetAdapter.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelTargetAdapter.java?rev=688611&r1=688610&r2=688611&view=diff
==============================================================================
---
activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelTargetAdapter.java
(original)
+++
activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelTargetAdapter.java
Sun Aug 24 20:54:47 2008
@@ -43,12 +43,12 @@
*
* @version $Revision$
*/
-public class CamelTargetAdapter extends AbstractCamelAdapter implements
MessageTarget, MessageBusAware {
+public class CamelTargetAdapter extends AbstractCamelAdapter implements
MessageTarget {
private final Log logger = LogFactory.getLog(this.getClass());
private ProducerTemplate<Exchange> camelTemplate;
private MessageChannel replyChannel;
- private MessageBus messageBus;
+
public void setReplyChannel(MessageChannel channel) {
replyChannel = channel;
@@ -95,12 +95,6 @@
}
}
return result;
-
}
- public void setMessageBus(MessageBus mBus) {
- messageBus = mBus;
- }
-
-
}