| Package | Description |
|---|---|
| org.cg.eventbus.stream |
| Modifier and Type | Method and Description |
|---|---|
void |
IHandler.handle(kafka.message.MessageAndMetadata<K,V> data,
IReporter reporter) |
| Constructor and Description |
|---|
Dispatcher(org.apache.commons.configuration.Configuration config,
IHandler handler,
IReporter reporter,
IPolicy policy) |
Copyright © 2016 CodeGerm. All rights reserved.