public EventBusEndpoint(String endpointUri) {
super(endpointUri);
}
-
+ @Override
public Producer createProducer() throws Exception {
return new EventBusProducer(this);
}
-
+ @Override
public Consumer createConsumer(Processor processor) throws Exception {
return new EventBusConsumer(this, processor);
}