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;
-    }
-
-
 }


Reply via email to