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 2017/04/06 07:39:10 UTC
camel git commit: CAMEL-11105 - add multipleconsumer support
Repository: camel
Updated Branches:
refs/heads/master fc70ee770 -> 0040c3bc1
CAMEL-11105 - add multipleconsumer support
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0040c3bc
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0040c3bc
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0040c3bc
Branch: refs/heads/master
Commit: 0040c3bc17a0fdd07123aa058f9058a94911459a
Parents: fc70ee7
Author: onders86 <on...@gmail.com>
Authored: Wed Apr 5 16:15:32 2017 +0300
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Apr 6 09:38:31 2017 +0200
----------------------------------------------------------------------
.../camel/component/eventadmin/EventAdminEndpoint.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/0040c3bc/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java b/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java
index 9da0735..68616cc 100644
--- a/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java
+++ b/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminEndpoint.java
@@ -17,6 +17,7 @@
package org.apache.camel.component.eventadmin;
import org.apache.camel.Consumer;
+import org.apache.camel.MultipleConsumersSupport;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
@@ -28,7 +29,7 @@ import org.apache.camel.spi.UriPath;
* The eventadmin component can be used in an OSGi environment to receive OSGi EventAdmin events and process them.
*/
@UriEndpoint(firstVersion = "2.6.0", scheme = "eventadmin", title = "OSGi EventAdmin", syntax = "eventadmin:topic", consumerClass = EventAdminConsumer.class, label = "eventbus")
-public class EventAdminEndpoint extends DefaultEndpoint {
+public class EventAdminEndpoint extends DefaultEndpoint implements MultipleConsumersSupport {
@UriPath
private final String topic;
@@ -76,4 +77,9 @@ public class EventAdminEndpoint extends DefaultEndpoint {
public boolean isSingleton() {
return true;
}
+
+ @Override
+ public boolean isMultipleConsumersSupported() {
+ return true;
+ }
}