You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2010/09/26 08:06:02 UTC
svn commit: r1001365 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultScheduledPollConsumer.java
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();
- }
}
}