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 <javiersantospani...@gmail.com> Authored: Fri Aug 29 14:25:01 2014 +0200 Committer: Claus Ibsen <davscl...@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; + } + }
