svn commit: r1300826 - /camel/trunk/camel-core/src/main/java/org/apache/camel/impl/InterceptSendToEndpoint.java

[ni...@apache.org]

Author: ningjiang
Date: Thu Mar 15 07:37:29 2012
New Revision: 1300826

URL: http://svn.apache.org/viewvc?rev=1300826&view=rev
Log:
CAMEL-5089 InterceptorSendToEndpoint should start and stop the producer which is intercepted

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/InterceptSendToEndpoint.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/InterceptSendToEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/InterceptSendToEndpoint.java?rev=1300826&r1=1300825&r2=1300826&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/InterceptSendToEndpoint.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/InterceptSendToEndpoint.java Thu Mar 15 07:37:29 2012
@@ -163,10 +163,14 @@ public class InterceptSendToEndpoint imp
 
             public void start() throws Exception {
                 ServiceHelper.startService(detour);
+                // here we also need to start the producer
+                ServiceHelper.startService(producer);
             }
 
             public void stop() throws Exception {
                 // do not stop detour as it should only be stopped when the interceptor stops
+                // we should stop the producer here
+                ServiceHelper.stopService(producer);
             }
         };
     }