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 2013/04/25 16:14:58 UTC
svn commit: r1475789 - in /camel/branches/camel-2.11.x: ./
components/camel-atom/src/main/java/org/apache/camel/component/atom/
components/camel-atom/src/main/java/org/apache/camel/component/feed/
components/camel-avro/src/main/java/org/apache/camel/co...
Author: davsclaus
Date: Thu Apr 25 14:14:56 2013
New Revision: 1475789
URL: http://svn.apache.org/r1475789
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/branches/camel-2.11.x/ (props changed)
camel/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java
camel/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java
camel/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java
camel/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java
camel/branches/camel-2.11.x/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java
camel/branches/camel-2.11.x/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java
camel/branches/camel-2.11.x/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java
camel/branches/camel-2.11.x/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java
camel/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
camel/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
camel/branches/camel-2.11.x/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java
camel/branches/camel-2.11.x/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java
camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java
camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java
camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java
camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java
camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java
camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java
camel/branches/camel-2.11.x/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
camel/branches/camel-2.11.x/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
camel/branches/camel-2.11.x/components/camel-http/ (props changed)
camel/branches/camel-2.11.x/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java
camel/branches/camel-2.11.x/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java
camel/branches/camel-2.11.x/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
camel/branches/camel-2.11.x/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java
camel/branches/camel-2.11.x/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java
camel/branches/camel-2.11.x/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java
camel/branches/camel-2.11.x/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
camel/branches/camel-2.11.x/components/camel-jms/ (props changed)
camel/branches/camel-2.11.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
camel/branches/camel-2.11.x/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
camel/branches/camel-2.11.x/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java
camel/branches/camel-2.11.x/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java
camel/branches/camel-2.11.x/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java
camel/branches/camel-2.11.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java
camel/branches/camel-2.11.x/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java
camel/branches/camel-2.11.x/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
camel/branches/camel-2.11.x/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java
camel/branches/camel-2.11.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
camel/branches/camel-2.11.x/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java
camel/branches/camel-2.11.x/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java
camel/branches/camel-2.11.x/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java
camel/branches/camel-2.11.x/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java
camel/branches/camel-2.11.x/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java
camel/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java
camel/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java
camel/branches/camel-2.11.x/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java
camel/branches/camel-2.11.x/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java
camel/branches/camel-2.11.x/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java
camel/branches/camel-2.11.x/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java
camel/branches/camel-2.11.x/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java
camel/branches/camel-2.11.x/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java
camel/branches/camel-2.11.x/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
camel/branches/camel-2.11.x/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java
camel/branches/camel-2.11.x/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java
camel/branches/camel-2.11.x/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
camel/branches/camel-2.11.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
camel/branches/camel-2.11.x/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
camel/branches/camel-2.11.x/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java
camel/branches/camel-2.11.x/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java
camel/branches/camel-2.11.x/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java
Propchange: camel/branches/camel-2.11.x/
------------------------------------------------------------------------------
Merged /camel/trunk:r1475786
Propchange: camel/branches/camel-2.11.x/
------------------------------------------------------------------------------
--- svnmerge-integrated (original)
+++ svnmerge-integrated Thu Apr 25 14:14:56 2013
@@ -1 +1 @@
-/camel/trunk:1-1468763,1469704,1469819,1470420,1470426-1470427,1470429,1470508,1471293,1471330,1471407-1471408,1471543,1475657,1475677,1475742
+/camel/trunk:1-1468763,1469704,1469819,1470420,1470426-1470427,1470429,1470508,1471293,1471330,1471407-1471408,1471543,1475657,1475677,1475742,1475786
Modified: camel/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-atom/src/main/java/org/apache/camel/component/feed/FeedEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-cache/src/main/java/org/apache/camel/component/cache/CacheEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java Thu Apr 25 14:14:56 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
Propchange: camel/branches/camel-2.11.x/components/camel-http/
------------------------------------------------------------------------------
Merged /camel/trunk/components/camel-http:r1475786
Modified: camel/branches/camel-2.11.x/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java Thu Apr 25 14:14:56 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) {
Propchange: camel/branches/camel-2.11.x/components/camel-jms/
------------------------------------------------------------------------------
Merged /camel/trunk/components/camel-jms:r1475786
Modified: camel/branches/camel-2.11.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java Thu Apr 25 14:14:56 2013
@@ -247,13 +247,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/branches/camel-2.11.x/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-kestrel/src/main/java/org/apache/camel/component/kestrel/KestrelEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2Endpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/direct/RouteboxDirectEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-routebox/src/main/java/org/apache/camel/component/routebox/seda/RouteboxSedaEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java Thu Apr 25 14:14:56 2013
@@ -117,7 +117,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/branches/camel-2.11.x/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java Thu Apr 25 14:14:56 2013
@@ -36,6 +36,7 @@ public class SpringWebserviceEndpoint ex
if (configuration.getEndpointDispatcher() != null) {
configuration.getEndpointDispatcher().setConsumerMessageEndpoint(consumer);
}
+ configureConsumer(consumer);
return consumer;
}
Modified: camel/branches/camel-2.11.x/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java (original)
+++ camel/branches/camel-2.11.x/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java Thu Apr 25 14:14:56 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/branches/camel-2.11.x/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.11.x/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java?rev=1475789&r1=1475788&r2=1475789&view=diff
==============================================================================
--- camel/branches/camel-2.11.x/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java (original)
+++ camel/branches/camel-2.11.x/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java Thu Apr 25 14:14:56 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() {