X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fevent%2FEventBusProducer.java;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fevent%2FEventBusProducer.java;h=dfd1bfe570092dfa731dd8891b03b216ed7b0ba6;hb=82f4f1ccada97fa394f88cf208ce526ff5ebf751;hp=dd8dbeddf410864a0a92b7b41ebd73d52a299842;hpb=9f43c23e7fbb4531fd045d081ddb59b5a547833c;p=aai%2Frouter-core.git

diff --git a/src/main/java/org/onap/aai/event/EventBusProducer.java b/src/main/java/org/onap/aai/event/EventBusProducer.java
index dd8dbed..dfd1bfe 100644
--- a/src/main/java/org/onap/aai/event/EventBusProducer.java
+++ b/src/main/java/org/onap/aai/event/EventBusProducer.java
@@ -22,17 +22,22 @@ package org.onap.aai.event;
 
 import org.apache.camel.Exchange;
 import org.apache.camel.impl.DefaultProducer;
+import org.onap.aai.event.api.EventPublisher;
 
 /**
  * The EventBus producer.
  */
 public class EventBusProducer extends DefaultProducer {
   private AbstractEventBusEndpoint endpoint;
+  
+  private EventPublisher publisher;
 
-  public EventBusProducer(AbstractEventBusEndpoint endpoint) {
-    super(endpoint);
-    this.endpoint = endpoint;
+  public EventBusProducer(AbstractEventBusEndpoint endpoint, EventPublisher publisher) {
+	    super(endpoint);
+	    this.endpoint = endpoint;
+	    this.publisher = publisher;
   }
+  
   @Override
   public void process(Exchange exchange) throws Exception {
     // Publishing to event bus is currently not supported