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

[ningjiang]

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