public class CurrentEventsByTagPublisher extends AbstractEventsByTagPublisher
ActorPublisher.Internal$
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
CurrentEventsByTagPublisher(java.lang.String tag,
long fromOffset,
long _toOffset,
int maxBufSize,
java.lang.String writeJournalPluginId) |
Modifier and Type | Method and Description |
---|---|
long |
_toOffset() |
void |
receiveIdleRequest() |
void |
receiveInitialRequest() |
void |
receiveRecoverySuccess(long highestSeqNr) |
long |
toOffset() |
buf, context, currOffset, fromOffset, idle, init, journal, maxBufSize, receive, replay, replaying, self, tag, timeForReplay, writeJournalPluginId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancelSelf, isActive, isCanceled, isCompleted, isErrorEmitted, onComplete, onCompleteThenStop, onError, onErrorThenStop, onNext, subscriptionTimeout, totalDemand
postRestart, postStop, preRestart, preStart, sender, supervisorStrategy, unhandled
deliverBuf
log
public CurrentEventsByTagPublisher(java.lang.String tag, long fromOffset, long _toOffset, int maxBufSize, java.lang.String writeJournalPluginId)
public long _toOffset()
public long toOffset()
toOffset
in class AbstractEventsByTagPublisher
public void receiveInitialRequest()
receiveInitialRequest
in class AbstractEventsByTagPublisher
public void receiveIdleRequest()
receiveIdleRequest
in class AbstractEventsByTagPublisher
public void receiveRecoverySuccess(long highestSeqNr)
receiveRecoverySuccess
in class AbstractEventsByTagPublisher