camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r1475786 - in /camel/trunk/components: camel-atom/src/main/java/org/apache/camel/component/atom/ camel-atom/src/main/java/org/apache/camel/component/feed/ camel-avro/src/main/java/org/apache/camel/component/avro/ camel-cache/src/main/java/o...
Date Thu, 25 Apr 2013 14:11:42 GMT
Author: davsclaus
Date: Thu Apr 25 14:11:40 2013
New Revision: 1475786

URL: http://svn.apache.org/r1475786
Log:
CAMEL-6312: When endpoints create Consumer make sure to configure consume as well so we can use the consumer. prefix from uris.

Modified:
    camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java
    camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java
    camel/trunk/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java
    camel/trunk/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java
    camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java
    camel/trunk/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java
    camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
    camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
    camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java
    camel/trunk/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java
    camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java
    camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java
    camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java
    camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java
    camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java
    camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java
    camel/trunk/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
    camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
    camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java
    camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java
    camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
    camel/trunk/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java
    camel/trunk/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java
    camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java
    camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
    camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
    camel/trunk/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
    camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java
    camel/trunk/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java
    camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java
    camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java
    camel/trunk/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java
    camel/trunk/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
    camel/trunk/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java
    camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
    camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java
    camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java
    camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java
    camel/trunk/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java
    camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java
    camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java
    camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java
    camel/trunk/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java
    camel/trunk/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java
    camel/trunk/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java
    camel/trunk/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java
    camel/trunk/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java
    camel/trunk/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java
    camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
    camel/trunk/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java
    camel/trunk/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java
    camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
    camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
    camel/trunk/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
    camel/trunk/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java
    camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java
    camel/trunk/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java

Modified: camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java (original)
+++ camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java Thu Apr 25 14:11:40 2013
@@ -54,12 +54,16 @@ public class AtomEndpoint extends FeedEn
     }
 
     @Override
-    protected FeedPollingConsumer createEntryPollingConsumer(FeedEndpoint feedEndpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries) {
-        return new AtomEntryPollingConsumer(this, processor, filter, lastUpdate, throttleEntries);
+    protected FeedPollingConsumer createEntryPollingConsumer(FeedEndpoint feedEndpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries) throws Exception {
+        AtomEntryPollingConsumer answer = new AtomEntryPollingConsumer(this, processor, filter, lastUpdate, throttleEntries);
+        configureConsumer(answer);
+        return answer;
     }  
     
     @Override
-    protected FeedPollingConsumer createPollingConsumer(FeedEndpoint feedEndpoint, Processor processor) {
-        return new AtomPollingConsumer(this, processor); 
+    protected FeedPollingConsumer createPollingConsumer(FeedEndpoint feedEndpoint, Processor processor) throws Exception {
+        AtomPollingConsumer answer = new AtomPollingConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 }

Modified: camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java (original)
+++ camel/trunk/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java Thu Apr 25 14:11:40 2013
@@ -71,9 +71,9 @@ public abstract class FeedEndpoint exten
         return answer;
     }
 
-    protected abstract FeedPollingConsumer createPollingConsumer(FeedEndpoint feedEndpoint, Processor processor);
+    protected abstract FeedPollingConsumer createPollingConsumer(FeedEndpoint feedEndpoint, Processor processor) throws Exception;
 
-    protected abstract FeedPollingConsumer createEntryPollingConsumer(FeedEndpoint feedEndpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries);
+    protected abstract FeedPollingConsumer createEntryPollingConsumer(FeedEndpoint feedEndpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries) throws Exception;
 
     protected Exchange createExchangeWithFeedHeader(Object feed, String header) {
         Exchange exchange = createExchange();

Modified: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java (original)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java Thu Apr 25 14:11:40 2013
@@ -58,6 +58,8 @@ public class AvroHttpEndpoint extends Av
      */
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new AvroHttpConsumer(this, processor);
+        AvroHttpConsumer answer = new AvroHttpConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 }

Modified: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java (original)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java Thu Apr 25 14:11:40 2013
@@ -58,6 +58,8 @@ public class AvroNettyEndpoint extends A
      */
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new AvroNettyConsumer(this, processor);
+        AvroNettyConsumer answer = new AvroNettyConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 }

Modified: camel/trunk/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java (original)
+++ camel/trunk/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java Thu Apr 25 14:11:40 2013
@@ -55,7 +55,9 @@ public class CacheEndpoint extends Defau
     public Consumer createConsumer(Processor processor) throws Exception {
         ObjectHelper.notNull(config, "config");
         ObjectHelper.notNull(cacheManagerFactory, "cacheManagerFactory");
-        return new CacheConsumer(this, processor, config);
+        CacheConsumer answer = new CacheConsumer(this, processor, config);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java (original)
+++ camel/trunk/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java Thu Apr 25 14:11:40 2013
@@ -49,7 +49,9 @@ public class CMISEndpoint extends Defaul
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new CMISConsumer(this, processor, sessionFacade);
+        CMISConsumer answer = new CMISConsumer(this, processor, sessionFacade);
+        configureConsumer(answer);
+        return answer;
     }
 
     public boolean isSingleton() {

Modified: camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java (original)
+++ camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java Thu Apr 25 14:11:40 2013
@@ -64,6 +64,7 @@ public class CometdEndpoint extends Defa
     public Consumer createConsumer(Processor processor) throws Exception {
         ObjectHelper.notNull(component, "component");
         CometdConsumer consumer = new CometdConsumer(this, processor);
+        configureConsumer(consumer);
         return consumer;
     }
 

Modified: camel/trunk/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java (original)
+++ camel/trunk/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java Thu Apr 25 14:11:40 2013
@@ -74,7 +74,9 @@ public class CouchDbEndpoint extends Def
 
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new CouchDbConsumer(this, createClient(), processor);
+        CouchDbConsumer answer = new CouchDbConsumer(this, createClient(), processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java (original)
+++ camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java Thu Apr 25 14:11:40 2013
@@ -203,7 +203,9 @@ public class CxfEndpoint extends Default
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new CxfConsumer(this, processor);
+        CxfConsumer answer = new CxfConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public boolean isSingleton() {

Modified: camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java (original)
+++ camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java Thu Apr 25 14:11:40 2013
@@ -129,7 +129,9 @@ public class CxfRsEndpoint extends Defau
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new CxfRsConsumer(this, processor);
+        CxfRsConsumer answer = new CxfRsConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java (original)
+++ camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java Thu Apr 25 14:11:40 2013
@@ -55,7 +55,9 @@ public class EventAdminEndpoint extends 
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new EventAdminConsumer(this, processor);
+        EventAdminConsumer answer = new EventAdminConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public boolean isSingleton() {

Modified: camel/trunk/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java (original)
+++ camel/trunk/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java Thu Apr 25 14:11:40 2013
@@ -48,7 +48,9 @@ public class GuavaEventBusEndpoint exten
 
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new GuavaEventBusConsumer(this, processor, eventBus, eventClass, listenerInterface);
+        GuavaEventBusConsumer answer = new GuavaEventBusConsumer(this, processor, eventBus, eventClass, listenerInterface);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java (original)
+++ camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java Thu Apr 25 14:11:40 2013
@@ -30,7 +30,9 @@ public class HazelcastInstanceEndpoint e
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new HazelcastInstanceConsumer(hazelcastInstance, this, processor);
+        HazelcastInstanceConsumer answer = new HazelcastInstanceConsumer(hazelcastInstance, this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java (original)
+++ camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java Thu Apr 25 14:11:40 2013
@@ -35,7 +35,9 @@ public class HazelcastListEndpoint exten
 
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new HazelcastListConsumer(hazelcastInstance, this, processor, cacheName);
+        HazelcastListConsumer answer = new HazelcastListConsumer(hazelcastInstance, this, processor, cacheName);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java (original)
+++ camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java Thu Apr 25 14:11:40 2013
@@ -30,7 +30,9 @@ public class HazelcastMapEndpoint extend
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new HazelcastMapConsumer(hazelcastInstance, this, processor, cacheName);
+        HazelcastMapConsumer answer = new HazelcastMapConsumer(hazelcastInstance, this, processor, cacheName);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java (original)
+++ camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java Thu Apr 25 14:11:40 2013
@@ -30,7 +30,9 @@ public class HazelcastMultimapEndpoint e
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new HazelcastMultimapConsumer(hazelcastInstance, this, processor, cacheName);
+        HazelcastMultimapConsumer answer = new HazelcastMultimapConsumer(hazelcastInstance, this, processor, cacheName);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java (original)
+++ camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java Thu Apr 25 14:11:40 2013
@@ -34,7 +34,9 @@ public class HazelcastQueueEndpoint exte
 
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new HazelcastQueueConsumer(hazelcastInstance, this, processor, cacheName);
+        HazelcastQueueConsumer answer = new HazelcastQueueConsumer(hazelcastInstance, this, processor, cacheName);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java (original)
+++ camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java Thu Apr 25 14:11:40 2013
@@ -49,7 +49,9 @@ public class HazelcastSedaEndpoint exten
     }
 
     public Consumer createConsumer(final Processor processor) throws Exception {
-        return new HazelcastSedaConsumer(this, processor);
+        HazelcastSedaConsumer answer = new HazelcastSedaConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public BlockingQueue<Object> getQueue() {

Modified: camel/trunk/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java (original)
+++ camel/trunk/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java Thu Apr 25 14:11:40 2013
@@ -65,6 +65,7 @@ public class HBaseEndpoint extends Defau
 
     public Consumer createConsumer(Processor processor) throws Exception {
         HBaseConsumer consumer =  new HBaseConsumer(this, processor, tablePool, tableName);
+        configureConsumer(consumer);
         consumer.setMaxMessagesPerPoll(maxMessagesPerPoll);
         return consumer;
     }

Modified: camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java (original)
+++ camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java Thu Apr 25 14:11:40 2013
@@ -37,9 +37,11 @@ public class HdfsEndpoint extends Defaul
     }
 
     @Override
-    public Consumer createConsumer(Processor processor) {
+    public Consumer createConsumer(Processor processor) throws Exception {
         config.checkConsumerOptions();
-        return new HdfsConsumer(this, processor, config);
+        HdfsConsumer answer = new HdfsConsumer(this, processor, config);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java (original)
+++ camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java Thu Apr 25 14:11:40 2013
@@ -94,7 +94,9 @@ public class HttpEndpoint extends Defaul
     }
 
     public PollingConsumer createPollingConsumer() throws Exception {
-        return new HttpPollingConsumer(this);
+        HttpPollingConsumer answer = new HttpPollingConsumer(this);
+        configureConsumer(answer);
+        return answer;
     }
 
     /**

Modified: camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java (original)
+++ camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java Thu Apr 25 14:11:40 2013
@@ -96,7 +96,9 @@ public class HttpEndpoint extends Defaul
     }
 
     public PollingConsumer createPollingConsumer() throws Exception {
-        return new HttpPollingConsumer(this);
+        HttpPollingConsumer answer = new HttpPollingConsumer(this);
+        configureConsumer(answer);
+        return answer;
     }
 
     /**

Modified: camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java (original)
+++ camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java Thu Apr 25 14:11:40 2013
@@ -117,7 +117,9 @@ public class IrcEndpoint extends Default
     }
 
     public IrcConsumer createConsumer(Processor processor) throws Exception {
-        return new IrcConsumer(this, processor, component.getIRCConnection(configuration));
+        IrcConsumer answer = new IrcConsumer(this, processor, component.getIRCConnection(configuration));
+        configureConsumer(answer);
+        return answer;
     }
 
     public IrcComponent getComponent() {

Modified: camel/trunk/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java (original)
+++ camel/trunk/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java Thu Apr 25 14:11:40 2013
@@ -83,7 +83,9 @@ public class JavaSpaceEndpoint extends D
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new JavaSpaceConsumer(this, processor);
+        JavaSpaceConsumer answer = new JavaSpaceConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public void setConcurrentConsumers(int concurrentConsumers) {

Modified: camel/trunk/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java (original)
+++ camel/trunk/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java Thu Apr 25 14:11:40 2013
@@ -42,8 +42,10 @@ public class JcloudsBlobStoreEndpoint ex
     }
 
     @Override
-    public Consumer createConsumer(Processor processor) {
-        return new JcloudsBlobStoreConsumer(this, processor, blobStore);
+    public Consumer createConsumer(Processor processor) throws Exception {
+        JcloudsBlobStoreConsumer answer = new JcloudsBlobStoreConsumer(this, processor, blobStore);
+        configureConsumer(answer);
+        return answer;
     }
 
     public String getLocationId() {

Modified: camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java (original)
+++ camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java Thu Apr 25 14:11:40 2013
@@ -70,12 +70,10 @@ public class JcrEndpoint extends Default
         }
     }
 
-    /**
-     * Currently unsupported
-     * @throws RuntimeCamelException
-     */
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new JcrConsumer(this, processor);
+        JcrConsumer answer = new JcrConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {
@@ -83,7 +81,7 @@ public class JcrEndpoint extends Default
     }
 
     public boolean isSingleton() {
-        return false;
+        return true;
     }
 
     /**

Modified: camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java (original)
+++ camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java Thu Apr 25 14:11:40 2013
@@ -105,7 +105,9 @@ public class JettyHttpEndpoint extends H
 
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new HttpConsumer(this, processor);
+        HttpConsumer answer = new HttpConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }   
 
     public void setSessionSupport(boolean support) {

Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java (original)
+++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java Thu Apr 25 14:11:40 2013
@@ -255,13 +255,16 @@ public class JmsEndpoint extends Default
     public JmsConsumer createConsumer(Processor processor, AbstractMessageListenerContainer listenerContainer) throws Exception {
         JmsConsumer consumer = new JmsConsumer(this, processor, listenerContainer);
         configureListenerContainer(listenerContainer, consumer);
+        configureConsumer(consumer);
         return consumer;
     }
 
     @Override
     public PollingConsumer createPollingConsumer() throws Exception {
         JmsOperations template = createInOnlyTemplate();
-        return new JmsPollingConsumer(this, template);
+        JmsPollingConsumer answer = new JmsPollingConsumer(this, template);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java (original)
+++ camel/trunk/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java Thu Apr 25 14:11:40 2013
@@ -221,10 +221,14 @@ public class JMXEndpoint extends Default
                     throw new IllegalArgumentException(ERR_THRESHOLD_LOW);
                 }
             }
-            return new JMXMonitorConsumer(this, aProcessor);
+            JMXMonitorConsumer answer = new JMXMonitorConsumer(this, aProcessor);
+            configureConsumer(answer);
+            return answer;
         } else {
             // shouldn't need any other validation.
-            return new JMXConsumer(this, aProcessor);
+            JMXConsumer answer = new JMXConsumer(this, aProcessor);
+            configureConsumer(answer);
+            return answer;
         }
     }
 

Modified: camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java (original)
+++ camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java Thu Apr 25 14:11:40 2013
@@ -142,7 +142,9 @@ public class Jt400DataQueueEndpoint exte
 
     @Override
     public PollingConsumer createPollingConsumer() throws Exception {
-        return new Jt400DataQueueConsumer(this);
+        Jt400DataQueueConsumer answer = new Jt400DataQueueConsumer(this);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java (original)
+++ camel/trunk/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java Thu Apr 25 14:11:40 2013
@@ -70,7 +70,9 @@ public class KestrelEndpoint extends Def
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new KestrelConsumer(this, processor, getMemcachedClient());
+        KestrelConsumer answer = new KestrelConsumer(this, processor, getMemcachedClient());
+        configureConsumer(answer);
+        return answer;
     }
 
     /**

Modified: camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java (original)
+++ camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java Thu Apr 25 14:11:40 2013
@@ -91,7 +91,9 @@ public class KratiEndpoint extends Defau
             dataStore = KratiHelper.createDataStore(path, initialCapacity, segmentFileSize, segmentFactory, hashFunction, keySerializer, valueSerializer);
             dataStoreRegistry.put(path, new KratiDataStoreRegistration(dataStore));
         }
-        return new KratiConsumer(this, processor, dataStore);
+        KratiConsumer answer = new KratiConsumer(this, processor, dataStore);
+        configureConsumer(answer);
+        return answer;
     }
 
     public boolean isSingleton() {

Modified: camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java (original)
+++ camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java Thu Apr 25 14:11:40 2013
@@ -85,7 +85,9 @@ public class MinaEndpoint extends Defaul
         if (!configuration.getProtocol().equalsIgnoreCase("vm")) {
             ObjectHelper.notNull(acceptorConfig, "acceptorConfig");
         }
-        return new MinaConsumer(this, processor);
+        MinaConsumer answer = new MinaConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Exchange createExchange(IoSession session, Object payload) {

Modified: camel/trunk/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java (original)
+++ camel/trunk/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java Thu Apr 25 14:11:40 2013
@@ -52,7 +52,9 @@ public class Mina2Endpoint extends Defau
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
         ObjectHelper.notNull(configuration, "configuration");
-        return new Mina2Consumer(this, processor);
+        Mina2Consumer answer = new Mina2Consumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Exchange createExchange(IoSession session, Object payload) {

Modified: camel/trunk/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java (original)
+++ camel/trunk/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java Thu Apr 25 14:11:40 2013
@@ -106,13 +106,14 @@ public class MongoDbEndpoint extends Def
             consumerType = MongoDbConsumerType.tailable;
         }
         
-        Consumer consumer = null;
+        Consumer consumer;
         if (consumerType == MongoDbConsumerType.tailable) {
             consumer = new MongoDbTailableCursorConsumer(this, processor);
         } else {
             throw new CamelMongoDbException("Consumer type not supported: " + consumerType);
         }
-        
+
+        configureConsumer(consumer);
         return consumer;
     }
 

Modified: camel/trunk/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java (original)
+++ camel/trunk/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java Thu Apr 25 14:11:40 2013
@@ -53,7 +53,9 @@ public class MQTTEndpoint extends Defaul
 
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new MQTTConsumer(this, processor);
+        MQTTConsumer answer = new MQTTConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java (original)
+++ camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java Thu Apr 25 14:11:40 2013
@@ -37,7 +37,9 @@ public class NettyEndpoint extends Defau
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new NettyConsumer(this, processor, configuration);
+        Consumer answer = new NettyConsumer(this, processor, configuration);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java (original)
+++ camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java Thu Apr 25 14:11:40 2013
@@ -47,7 +47,9 @@ public class PaxLoggingEndpoint extends 
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new PaxLoggingConsumer(this, processor);
+        PaxLoggingConsumer answer = new PaxLoggingConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public boolean isSingleton() {

Modified: camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java (original)
+++ camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java Thu Apr 25 14:11:40 2013
@@ -139,7 +139,9 @@ public class QuartzEndpoint extends Defa
     }
 
     public QuartzConsumer createConsumer(Processor processor) throws Exception {
-        return new QuartzConsumer(this, processor);
+        QuartzConsumer answer = new QuartzConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java (original)
+++ camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java Thu Apr 25 14:11:40 2013
@@ -68,6 +68,7 @@ public class QuickfixjEndpoint extends D
     public Consumer createConsumer(Processor processor) throws Exception {
         LOG.info("Creating QuickFIX/J consumer: {}, ExchangePattern={}", sessionID != null ? sessionID : "No Session", getExchangePattern());
         QuickfixjConsumer consumer = new QuickfixjConsumer(this, processor);
+        configureConsumer(consumer);
         consumers.add(consumer);
         return consumer;
     }

Modified: camel/trunk/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java (original)
+++ camel/trunk/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java Thu Apr 25 14:11:40 2013
@@ -75,7 +75,9 @@ public class RestletEndpoint extends Def
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new RestletConsumer(this, processor);
+        RestletConsumer answer = new RestletConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java (original)
+++ camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java Thu Apr 25 14:11:40 2013
@@ -64,12 +64,14 @@ public class RmiEndpoint extends Default
         return uri.toString();
     }
 
-    public Consumer createConsumer(Processor processor) {
+    public Consumer createConsumer(Processor processor) throws Exception {
         ObjectHelper.notNull(uri, "uri");
         if (remoteInterfaces == null || remoteInterfaces.size() == 0) {
             throw new IllegalArgumentException("To create a RMI consumer, the RMI endpoint's remoteInterfaces property must be be configured.");
         }
-        return new RmiConsumer(this, processor);
+        RmiConsumer answer = new RmiConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java (original)
+++ camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java Thu Apr 25 14:11:40 2013
@@ -47,7 +47,9 @@ public class RouteboxDirectEndpoint exte
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new RouteboxDirectConsumer(this, processor);
+        RouteboxDirectConsumer answer = new RouteboxDirectConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public boolean isSingleton() {

Modified: camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java (original)
+++ camel/trunk/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java Thu Apr 25 14:11:40 2013
@@ -53,7 +53,9 @@ public class RouteboxSedaEndpoint extend
     }
     
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new RouteboxSedaConsumer(this, processor);        
+        RouteboxSedaConsumer answer = new RouteboxSedaConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java (original)
+++ camel/trunk/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java Thu Apr 25 14:11:40 2013
@@ -56,7 +56,7 @@ public class RssEndpoint extends FeedEnd
             newFeed = (SyndFeed)((SyndFeed) feed).clone();
             newFeed.setEntries(Arrays.asList(entry));
         } catch (CloneNotSupportedException e) {
-            LOG.debug("Could not create a new feed.", e);
+            LOG.debug("Could not create a new feed. This exception will be ignored.", e);
             newFeed = null;
         }        
         exchange.getIn().setBody(newFeed);
@@ -65,12 +65,16 @@ public class RssEndpoint extends FeedEnd
 
     @Override
     protected FeedPollingConsumer createEntryPollingConsumer(FeedEndpoint feedEndpoint, Processor processor,
-                                                             boolean filter, Date lastUpdate, boolean throttleEntries) {
-        return new RssEntryPollingConsumer(this, processor, filter, lastUpdate, throttleEntries);
+                                                             boolean filter, Date lastUpdate, boolean throttleEntries) throws Exception {
+        RssEntryPollingConsumer answer = new RssEntryPollingConsumer(this, processor, filter, lastUpdate, throttleEntries);
+        configureConsumer(answer);
+        return answer;
     }  
     
     @Override
-    protected FeedPollingConsumer createPollingConsumer(FeedEndpoint feedEndpoint, Processor processor) {
-        return new RssPollingConsumer(this, processor); 
+    protected FeedPollingConsumer createPollingConsumer(FeedEndpoint feedEndpoint, Processor processor) throws Exception {
+        RssPollingConsumer answer = new RssPollingConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 }

Modified: camel/trunk/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java (original)
+++ camel/trunk/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java Thu Apr 25 14:11:40 2013
@@ -54,7 +54,9 @@ public class ServletEndpoint extends Htt
 
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new ServletConsumer(this, processor);
+        ServletConsumer answer = new ServletConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java (original)
+++ camel/trunk/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java Thu Apr 25 14:11:40 2013
@@ -32,9 +32,13 @@ public class SipEndpoint extends Default
 
     public Consumer createConsumer(Processor processor) throws Exception {
         if (configuration.isPresenceAgent()) {
-            return new SipPresenceAgent(this, processor, configuration);
+            SipPresenceAgent answer = new SipPresenceAgent(this, processor, configuration);
+            configureConsumer(answer);
+            return answer;
         } else {
-            return new SipSubscriber(this, processor, configuration);
+            SipSubscriber answer = new SipSubscriber(this, processor, configuration);
+            configureConsumer(answer);
+            return answer;
         }
     }
 

Modified: camel/trunk/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java (original)
+++ camel/trunk/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java Thu Apr 25 14:11:40 2013
@@ -133,7 +133,9 @@ public class SjmsEndpoint extends Defaul
 
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new SjmsConsumer(this, processor);
+        SjmsConsumer answer = new SjmsConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java (original)
+++ camel/trunk/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java Thu Apr 25 14:11:40 2013
@@ -57,7 +57,9 @@ public class SmppEndpoint extends Defaul
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new SmppConsumer(this, configuration, processor);
+        SmppConsumer answer = new SmppConsumer(this, configuration, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java (original)
+++ camel/trunk/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java Thu Apr 25 14:11:40 2013
@@ -62,9 +62,13 @@ public class SnmpEndpoint extends Defaul
 
     public Consumer createConsumer(Processor processor) throws Exception {
         if (this.type == SnmpActionType.TRAP) {
-            return new SnmpTrapConsumer(this, processor);
+            SnmpTrapConsumer answer = new SnmpTrapConsumer(this, processor);
+            configureConsumer(answer);
+            return answer;
         } else if (this.type == SnmpActionType.POLL) {
-            return new SnmpOIDPoller(this, processor);
+            SnmpOIDPoller answer = new SnmpOIDPoller(this, processor);
+            configureConsumer(answer);
+            return answer;
         } else {
             throw new IllegalArgumentException("The type '" + this.type + "' is not valid!");
         }

Modified: camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java (original)
+++ camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java Thu Apr 25 14:11:40 2013
@@ -58,7 +58,9 @@ public class SpringIntegrationEndpoint e
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new SpringIntegrationConsumer(this, processor);
+        SpringIntegrationConsumer answer = new SpringIntegrationConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public void setInputChannel(String input) {

Modified: camel/trunk/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java (original)
+++ camel/trunk/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java Thu Apr 25 14:11:40 2013
@@ -37,7 +37,9 @@ public class RedisEndpoint extends Direc
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new RedisConsumer(this, processor, configuration);
+        RedisConsumer answer = new RedisConsumer(this, processor, configuration);
+        configureConsumer(answer);
+        return answer;
     }
 
     public boolean isSingleton() {

Modified: camel/trunk/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java (original)
+++ camel/trunk/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java Thu Apr 25 14:11:40 2013
@@ -36,6 +36,7 @@ public class SpringWebserviceEndpoint ex
         if (configuration.getEndpointDispatcher() != null) {
             configuration.getEndpointDispatcher().setConsumerMessageEndpoint(consumer);
         }
+        configureConsumer(consumer);
         return consumer;
     }
 

Modified: camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java (original)
+++ camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java Thu Apr 25 14:11:40 2013
@@ -81,7 +81,9 @@ public class EventEndpoint extends Defau
 
     public EventConsumer createConsumer(Processor processor) throws Exception {
         ObjectHelper.notNull(applicationContext, "applicationContext");
-        return new EventConsumer(this, processor);
+        EventConsumer answer = new EventConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public void onApplicationEvent(ApplicationEvent event) {

Modified: camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java (original)
+++ camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java Thu Apr 25 14:11:40 2013
@@ -57,7 +57,9 @@ public class StreamEndpoint extends Defa
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new StreamConsumer(this, processor, getEndpointUri());
+        StreamConsumer answer = new StreamConsumer(this, processor, getEndpointUri());
+        configureConsumer(answer);
+        return answer;
     }
 
     public Producer createProducer() throws Exception {

Modified: camel/trunk/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java (original)
+++ camel/trunk/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java Thu Apr 25 14:11:40 2013
@@ -40,7 +40,9 @@ public class TwitterEndpointDirect exten
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
         Twitter4JConsumer twitter4jConsumer = Twitter4JFactory.getConsumer(this, getEndpointUri());
-        return new TwitterConsumerDirect(this, processor, twitter4jConsumer);
+        TwitterConsumerDirect answer = new TwitterConsumerDirect(this, processor, twitter4jConsumer);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java (original)
+++ camel/trunk/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java Thu Apr 25 14:11:40 2013
@@ -78,6 +78,7 @@ public class WebsocketEndpoint extends D
     public Consumer createConsumer(Processor processor) throws Exception {
         ObjectHelper.notNull(component, "component");
         WebsocketConsumer consumer = new WebsocketConsumer(this, processor);
+        configureConsumer(consumer);
         return consumer;
     }
 

Modified: camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java (original)
+++ camel/trunk/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java Thu Apr 25 14:11:40 2013
@@ -97,7 +97,9 @@ public class XmppEndpoint extends Defaul
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new XmppConsumer(this, processor);
+        XmppConsumer answer = new XmppConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     @Override

Modified: camel/trunk/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java?rev=1475786&r1=1475785&r2=1475786&view=diff
==============================================================================
--- camel/trunk/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java (original)
+++ camel/trunk/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java Thu Apr 25 14:11:40 2013
@@ -45,7 +45,9 @@ public class ZooKeeperEndpoint extends D
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new ZooKeeperConsumer(this, processor);
+        ZooKeeperConsumer answer = new ZooKeeperConsumer(this, processor);
+        configureConsumer(answer);
+        return answer;
     }
 
     public boolean isSingleton() {



Mime
View raw message