diff options
| author |   Gurjeet Bedi <gurjeetb@amdocs.com> | 2018-06-14 12:20:23 -0400 |
|---|---|---|
| committer | Gurjeet Bedi <gurjeetb@amdocs.com> | 2018-06-14 12:23:01 -0400 |
| commit | 82f4f1ccada97fa394f88cf208ce526ff5ebf751 (patch) | |
| tree | 8c00238ce92f2eea8990580f7de0a4dd7acbe540 /src/main/java/org/onap/aai/event/EventBusProducer.java | |
| parent | 9f43c23e7fbb4531fd045d081ddb59b5a547833c (diff) | |
Make generic router core implementations
Remove dependency of implementation classes of event client
Issue-ID: AAI-1228
Change-Id: I464439e225de6b32941257c090932bd2f6066dc8
Signed-off-by: Gurjeet Bedi <gurjeetb@amdocs.com>
Diffstat (limited to 'src/main/java/org/onap/aai/event/EventBusProducer.java')
| -rw-r--r-- | src/main/java/org/onap/aai/event/EventBusProducer.java | 11 |
1 files changed, 8 insertions, 3 deletions
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 |