camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [3/4] camel git commit: Added support for multiple consumers at HazelcastTopicEndPoint
Date Wed, 03 Dec 2014 19:01:51 GMT
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 <javiersantospaniego@gmail.com>
Authored: Fri Aug 29 14:25:01 2014 +0200
Committer: Claus Ibsen <davsclaus@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;
+    }
+
 }


Mime
View raw message