public Producer createProducer() throws Exception {
return new EventBusProducer(this);
}
-
+ @Override
public Consumer createConsumer(Processor processor) throws Exception {
return new EventBusConsumer(this, processor);
}
-
+ @Override
public boolean isSingleton() {
return false;
}