| Package | Description |
|---|---|
| org.cg.eventbus.consumer.bytestream | |
| org.cg.eventbus.parser | |
| org.cg.eventbus.policy |
| Modifier and Type | Method and Description |
|---|---|
Message |
GenericFetcher.read() |
| Modifier and Type | Method and Description |
|---|---|
abstract V |
MessageParser.parser(Message msg) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
StrictCommitPolicy.needCommit(Message msg) |
abstract boolean |
CommitPolicy.needCommit(Message msg) |
Copyright © 2016 CodeGerm. All rights reserved.