public abstract class BaseMessageChooser extends java.lang.Object implements MessageChooser
Constructor and Description |
---|
BaseMessageChooser() |
Modifier and Type | Method and Description |
---|---|
void |
register(SystemStreamPartition systemStreamPartition,
java.lang.String offset)
Called before start, to let the chooser know that it will be handling
envelopes from the given SystemStreamPartition.
|
void |
start()
Called after all SystemStreamPartitions have been registered.
|
void |
stop()
Called when the chooser is about to be discarded.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
choose, update
public void start()
MessageChooser
start
in interface MessageChooser
public void stop()
MessageChooser
stop
in interface MessageChooser
public void register(SystemStreamPartition systemStreamPartition, java.lang.String offset)
MessageChooser
register
in interface MessageChooser
systemStreamPartition
- A SystemStreamPartition that envelopes will be coming from.offset
- The offset of the first message expected for the
system/stream/partition that's being registered. If "7" were
supplied as the offset, then the MessageChooser can expect the
first message it is updated with for the system/stream/partition
will have an offset of "7".