| Package | Description |
|---|---|
| org.cg.eventbus | |
| org.cg.eventbus.consumer | |
| org.cg.eventbus.producer |
| Modifier and Type | Interface and Description |
|---|---|
interface |
IManager<K,V> |
interface |
IProducer<K,V>
interface to further simplify the pub sub api
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
IConsumer<K,V> |
| Modifier and Type | Class and Description |
|---|---|
class |
SymmetricDispatcher<K,V>
SymmetricDispatcher has one kafka consumer, dispatcher can be launched into
multiple processes, kafka should auto balance its consumers therefore it is
symmetric.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractEventProducer<K,V>
Producer using string key to partition
|
Copyright © 2016 CodeGerm. All rights reserved.