public class CurrentEventsByPersistenceIdPublisher extends AbstractEventsByPersistenceIdPublisher
ActorPublisher.Internal$
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
CurrentEventsByPersistenceIdPublisher(java.lang.String persistenceId,
long fromSequenceNr,
long toSeqNr,
int maxBufSize,
java.lang.String writeJournalPluginId) |
Modifier and Type | Method and Description |
---|---|
void |
receiveIdleRequest() |
void |
receiveInitialRequest() |
void |
receiveRecoverySuccess(long highestSeqNr) |
long |
toSeqNr() |
long |
toSequenceNr() |
buf, context, currSeqNo, fromSequenceNr, idle, init, journal, maxBufSize, persistenceId, receive, replay, replaying, self, 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 CurrentEventsByPersistenceIdPublisher(java.lang.String persistenceId, long fromSequenceNr, long toSeqNr, int maxBufSize, java.lang.String writeJournalPluginId)
public long toSeqNr()
public long toSequenceNr()
toSequenceNr
in class AbstractEventsByPersistenceIdPublisher
public void receiveInitialRequest()
receiveInitialRequest
in class AbstractEventsByPersistenceIdPublisher
public void receiveIdleRequest()
receiveIdleRequest
in class AbstractEventsByPersistenceIdPublisher
public void receiveRecoverySuccess(long highestSeqNr)
receiveRecoverySuccess
in class AbstractEventsByPersistenceIdPublisher