svn commit: r1001365 - /camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultScheduledPollConsumer.java

[davsclaus]

Author: davsclaus
Date: Sun Sep 26 06:06:02 2010
New Revision: 1001365

URL: http://svn.apache.org/viewvc?rev=1001365&view=rev
Log:
CAMEL-3158: Calling start/stop on created service.

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

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultScheduledPollConsumer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultScheduledPollConsumer.java?rev=1001365&r1=1001364&r2=1001365&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultScheduledPollConsumer.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultScheduledPollConsumer.java
 Sun Sep 26 06:06:02 2010
@@ -22,6 +22,7 @@ import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.PollingConsumer;
 import org.apache.camel.Processor;
+import org.apache.camel.util.ServiceHelper;
 
 /**
  * A default implementation of an event driven {...@link 
org.apache.camel.Consumer} which uses the
@@ -62,14 +63,13 @@ public class DefaultScheduledPollConsume
     @Override
     protected void doStart() throws Exception {
         pollingConsumer = getEndpoint().createPollingConsumer();
+        ServiceHelper.startService(pollingConsumer);
         super.doStart();
     }
 
     @Override
     protected void doStop() throws Exception {
+        ServiceHelper.stopService(pollingConsumer);
         super.doStop();
-        if (pollingConsumer != null) {
-            pollingConsumer.stop();
-        }
     }
 }