public class LiveEventsByPersistenceIdPublisher extends AbstractEventsByPersistenceIdPublisher
Constructor and Description |
---|
LiveEventsByPersistenceIdPublisher(java.lang.String persistenceId,
long fromSequenceNr,
long toSequenceNr,
scala.concurrent.duration.FiniteDuration refreshInterval,
int maxBufSize,
java.lang.String writeJournalPluginId) |
Modifier and Type | Method and Description |
---|---|
void |
postStop() |
void |
receiveIdleRequest() |
void |
receiveInitialRequest() |
void |
receiveRecoverySuccess(long highestSeqNr) |
akka.actor.Cancellable |
tickTask() |
long |
toSequenceNr() |
currSeqNo, fromSequenceNr, idle, init, journal, maxBufSize, persistenceId, receive, replay, replaying, timeForReplay, writeJournalPluginId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$stream$actor$ActorPublisher$_setter_$akka$stream$actor$ActorPublisher$$state_$eq, akka$stream$actor$ActorPublisher$$demand_$eq, akka$stream$actor$ActorPublisher$$demand, akka$stream$actor$ActorPublisher$$lifecycleState_$eq, akka$stream$actor$ActorPublisher$$lifecycleState, akka$stream$actor$ActorPublisher$$scheduledSubscriptionTimeout_$eq, akka$stream$actor$ActorPublisher$$scheduledSubscriptionTimeout, akka$stream$actor$ActorPublisher$$state, akka$stream$actor$ActorPublisher$$subscriber_$eq, akka$stream$actor$ActorPublisher$$subscriber, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, isActive, isCanceled, isCompleted, isErrorEmitted, onComplete, onCompleteThenStop, onError, onErrorThenStop, onNext, subscriptionTimeout, totalDemand
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled
buf, deliverBuf
public LiveEventsByPersistenceIdPublisher(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr, scala.concurrent.duration.FiniteDuration refreshInterval, int maxBufSize, java.lang.String writeJournalPluginId)
public long toSequenceNr()
toSequenceNr
in class AbstractEventsByPersistenceIdPublisher
public akka.actor.Cancellable tickTask()
public void postStop()
public void receiveInitialRequest()
receiveInitialRequest
in class AbstractEventsByPersistenceIdPublisher
public void receiveIdleRequest()
receiveIdleRequest
in class AbstractEventsByPersistenceIdPublisher
public void receiveRecoverySuccess(long highestSeqNr)
receiveRecoverySuccess
in class AbstractEventsByPersistenceIdPublisher