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 2014/12/03 20:01:51 UTC
[3/4] camel git commit: Added support for multiple consumers at
HazelcastTopicEndPoint
Added support for multiple consumers at HazelcastTopicEndPoint
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a97d8b95
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a97d8b95
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a97d8b95
Branch: refs/heads/master
Commit: a97d8b95eb038a61d4aaeaf47fd9d5670cb169c0
Parents: 69138a1
Author: JSantosP <ja...@gmail.com>
Authored: Fri Aug 29 14:25:01 2014 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Wed Dec 3 19:57:22 2014 +0100
----------------------------------------------------------------------
.../component/hazelcast/topic/HazelcastTopicEndpoint.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/a97d8b95/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java
index 920be2e..d74d780 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java
@@ -21,12 +21,13 @@ import org.apache.camel.Component;
import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
+import org.apache.camel.MultipleConsumersSupport;
import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint;
/**
*
*/
-public class HazelcastTopicEndpoint extends HazelcastDefaultEndpoint {
+public class HazelcastTopicEndpoint extends HazelcastDefaultEndpoint implements MultipleConsumersSupport {
public HazelcastTopicEndpoint(HazelcastInstance hazelcastInstance, String endpointUri, Component component, String cacheName) {
super(hazelcastInstance, endpointUri, component, cacheName);
@@ -44,4 +45,9 @@ public class HazelcastTopicEndpoint extends HazelcastDefaultEndpoint {
return new HazelcastTopicProducer(hazelcastInstance, this, cacheName);
}
+ @Override
+ public boolean isMultipleConsumersSupported() {
+ return true;
+ }
+
}