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 e39ce36..26e4258 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;
 
 /**
  * An 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(getConfigurationAdmin());
             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(getConfigurationAdmin());
             producer.init();
             return producer;
         }
@@ -88,4 +92,12 @@ public class HazelcastEventTransportFactory extends HazelcastInstanceAware imple
         this.combinedClassLoader = combinedClassLoader;
     }
 
+    public ConfigurationAdmin getConfigurationAdmin() {
+		    return configurationAdmin;
+	  }
+
+	  public void setConfigurationAdmin(ConfigurationAdmin configurationAdmin) {
+		    this.configurationAdmin = configurationAdmin;
+	  }
+
 }
diff --git a/hazelcast/src/main/resources/OSGI-INF/blueprint/blueprint.xml b/hazelcast/src/main/resources/OSGI-INF/blueprint/blueprint.xml
index 77bc51e..76b0e05 100644
--- a/hazelcast/src/main/resources/OSGI-INF/blueprint/blueprint.xml
+++ b/hazelcast/src/main/resources/OSGI-INF/blueprint/blueprint.xml
@@ -69,6 +69,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"/>