| |
|
| java.lang.Object com.tc.async.impl.OrderedSink
OrderedSink | public class OrderedSink implements Sink(Code) | | This class provides an order to the events processed. If events are added out of order, this class orderes them
before adding it to the destination sink. If Messages went missing, then this class waits till the missing message
arrives before pushing the events to the destination sink.
|
addLossy | public boolean addLossy(EventContext context)(Code) | | this implementation isnt really lossy.
|
clear | public synchronized void clear()(Code) | | |
enableStatsCollection | public void enableStatsCollection(boolean enable)(Code) | | |
getStatsAndReset | public Stats getStatsAndReset(long frequency)(Code) | | |
isStatsCollectionEnabled | public boolean isStatsCollectionEnabled()(Code) | | |
resetStats | public void resetStats()(Code) | | |
unpause | public void unpause()(Code) | | |
|
|
|