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 2009/08/25 13:39:56 UTC
svn commit: r807571 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
Author: davsclaus
Date: Tue Aug 25 11:39:55 2009
New Revision: 807571
URL: http://svn.apache.org/viewvc?rev=807571&view=rev
Log:
CAMEL-1933: Added getEndpoint to consumers.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java?rev=807571&r1=807570&r2=807571&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java Tue Aug 25 11:39:55 2009
@@ -23,6 +23,7 @@
import org.apache.camel.Consumer;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
+import org.apache.camel.Endpoint;
import org.apache.camel.impl.ServiceSupport;
import org.apache.camel.util.concurrent.ExecutorServiceHelper;
import org.apache.commons.logging.Log;
@@ -50,6 +51,10 @@
return "SedaConsumer[" + endpoint.getEndpointUri() + "]";
}
+ public Endpoint getEndpoint() {
+ return endpoint;
+ }
+
public void run() {
BlockingQueue<Exchange> queue = endpoint.getQueue();
while (queue != null && isRunAllowed()) {
@@ -90,7 +95,6 @@
protected void doStop() throws Exception {
endpoint.onStopped(this);
-
executor.shutdownNow();
executor = null;
}