Code Review
/
aai
/
router-core.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Make generic router core implementations
[aai/router-core.git]
/
src
/
main
/
java
/
org
/
onap
/
aai
/
event
/
EventBusProducer.java
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
(file)
--- 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.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;
/**
* 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
@Override
public void process(Exchange exchange) throws Exception {
// Publishing to event bus is currently not supported