public interface IExitCondition
Most of the time because enough data was received (i.e. acks is greater than some value), or because there are some failure (fails greater than 0).
Another likely case is to have no more activity after some data was received.
A callback must be provided when creating the exit condition. It should contain the exit protocol.
Modifier and Type | Method and Description |
---|---|
void |
evaluate()
Evaluate the exit conditions and fire the callback if matched.
|
void |
incRemainingObjects(long increment)
Indicates that some remaining object is to be handled (semantics: depending on the spout)
|
boolean |
isEnabled()
State whether exit condition will be used or not
|
void |
markAck()
Signal a data ack.
|
void |
markEmit()
Signal a data emit.
|
void |
markFail()
Signal a data failure.
|
void markEmit()
void markAck()
void markFail()
void incRemainingObjects(long increment)
increment
- void evaluate()
boolean isEnabled()
Copyright © 2014–2023. All rights reserved.