You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2013/12/18 13:27:56 UTC
[41/50] git commit: [KARAF-2478] Producer and consumer status is
updated when configuration is changed on the cluster
[KARAF-2478] Producer and consumer status is updated when configuration is changed on the cluster
git-svn-id: https://svn.apache.org/repos/asf/karaf/cellar/branches/cellar-2.3.x@1528840 13f79535-47bb-0310-9956-ffa450edef68
Project: http://git-wip-us.apache.org/repos/asf/karaf-cellar/repo
Commit: http://git-wip-us.apache.org/repos/asf/karaf-cellar/commit/dcd671e1
Tree: http://git-wip-us.apache.org/repos/asf/karaf-cellar/tree/dcd671e1
Diff: http://git-wip-us.apache.org/repos/asf/karaf-cellar/diff/dcd671e1
Branch: refs/heads/cellar-2.3.x
Commit: dcd671e1372529eee98e88c3b6a3fd1828a6df4b
Parents: 388b42f
Author: jbonofre <jb...@13f79535-47bb-0310-9956-ffa450edef68>
Authored: Thu Oct 3 13:03:58 2013 +0000
Committer: jbonofre <jb...@13f79535-47bb-0310-9956-ffa450edef68>
Committed: Thu Oct 3 13:03:58 2013 +0000
----------------------------------------------------------------------
.../hazelcast/HazelcastEventTransportFactory.java | 14 ++++++++++++++
.../main/resources/OSGI-INF/blueprint/blueprint.xml | 1 +
2 files changed, 15 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/dcd671e1/hazelcast/src/main/java/org/apache/karaf/cellar/hazelcast/HazelcastEventTransportFactory.java
----------------------------------------------------------------------
diff --git a/hazelcast/src/main/java/org/apache/karaf/cellar/hazelcast/HazelcastEventTransportFactory.java b/hazelcast/src/main/java/org/apache/karaf/cellar/hazelcast/HazelcastEventTransportFactory.java
index d947e69..6f2c1ef 100644
--- a/hazelcast/src/main/java/org/apache/karaf/cellar/hazelcast/HazelcastEventTransportFactory.java
+++ b/hazelcast/src/main/java/org/apache/karaf/cellar/hazelcast/HazelcastEventTransportFactory.java
@@ -20,6 +20,7 @@ import org.apache.karaf.cellar.core.event.EventConsumer;
import org.apache.karaf.cellar.core.event.EventProducer;
import org.apache.karaf.cellar.core.event.EventTransportFactory;
import org.apache.karaf.cellar.core.utils.CombinedClassLoader;
+import org.osgi.service.cm.ConfigurationAdmin;
/**
* A cluster event transport factory powered by Hazelcast.
@@ -28,6 +29,7 @@ public class HazelcastEventTransportFactory extends HazelcastInstanceAware imple
private Dispatcher dispatcher;
private CombinedClassLoader combinedClassLoader;
+ private ConfigurationAdmin configurationAdmin;
@Override
public EventProducer getEventProducer(String name, Boolean pubsub) {
@@ -37,6 +39,7 @@ public class HazelcastEventTransportFactory extends HazelcastInstanceAware imple
producer.setInstance(instance);
producer.setTopic(topic);
producer.setNode(getNode());
+ producer.setConfigurationAdmin(configurationAdmin);
producer.init();
return producer;
} else {
@@ -44,6 +47,7 @@ public class HazelcastEventTransportFactory extends HazelcastInstanceAware imple
QueueProducer producer = new QueueProducer();
producer.setQueue(queue);
producer.setNode(getNode());
+ producer.setConfigurationAdmin(configurationAdmin);
producer.init();
return producer;
}
@@ -58,6 +62,7 @@ public class HazelcastEventTransportFactory extends HazelcastInstanceAware imple
consumer.setInstance(instance);
consumer.setNode(getNode());
consumer.setDispatcher(dispatcher);
+ consumer.setConfigurationAdmin(configurationAdmin);
consumer.init();
return consumer;
} else {
@@ -66,6 +71,7 @@ public class HazelcastEventTransportFactory extends HazelcastInstanceAware imple
consumer.setQueue(queue);
consumer.setNode(getNode());
consumer.setDispatcher(dispatcher);
+ consumer.setConfigurationAdmin(configurationAdmin);
consumer.init();
return consumer;
}
@@ -87,4 +93,12 @@ public class HazelcastEventTransportFactory extends HazelcastInstanceAware imple
this.combinedClassLoader = combinedClassLoader;
}
+ public ConfigurationAdmin getConfigurationAdmin() {
+ return configurationAdmin;
+ }
+
+ public void setConfigurationAdmin(ConfigurationAdmin configurationAdmin) {
+ this.configurationAdmin = configurationAdmin;
+ }
+
}
http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/dcd671e1/hazelcast/src/main/resources/OSGI-INF/blueprint/blueprint.xml
----------------------------------------------------------------------
diff --git a/hazelcast/src/main/resources/OSGI-INF/blueprint/blueprint.xml b/hazelcast/src/main/resources/OSGI-INF/blueprint/blueprint.xml
index 0b43545..2f626d7 100644
--- a/hazelcast/src/main/resources/OSGI-INF/blueprint/blueprint.xml
+++ b/hazelcast/src/main/resources/OSGI-INF/blueprint/blueprint.xml
@@ -73,6 +73,7 @@
<property name="dispatcher" ref="dispatcher"/>
<property name="instance" ref="hazelcast"/>
<property name="combinedClassLoader" ref="combinedClassLoader"/>
+ <property name="configurationAdmin" ref="configurationAdmin"/>
</bean>
<service ref="eventTransportFactory" interface="org.apache.karaf.cellar.core.event.EventTransportFactory"/>