akka.persistence.query.journal.leveldb

Class LiveEventsByPersistenceIdPublisher

java.lang.Object

akka.persistence.query.journal.leveldb.AbstractEventsByPersistenceIdPublisher

akka.persistence.query.journal.leveldb.LiveEventsByPersistenceIdPublisher

All Implemented Interfaces:

Actor, ActorLogging, DeliveryBuffer<EventEnvelope>, ActorPublisher<EventEnvelope>

public class LiveEventsByPersistenceIdPublisher
extends AbstractEventsByPersistenceIdPublisher

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from interface akka.stream.actor.ActorPublisher

ActorPublisher.Internal$

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
LiveEventsByPersistenceIdPublisher(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr, scala.concurrent.duration.FiniteDuration refreshInterval, int maxBufSize, java.lang.String writeJournalPluginId)

Method Summary

Modifier and Type	Method and Description
void	postStop() User overridable callback.
void	receiveIdleRequest()
void	receiveInitialRequest()
void	receiveRecoverySuccess(long highestSeqNr)
Cancellable	tickTask()
long	toSequenceNr()

Methods inherited from class akka.persistence.query.journal.leveldb.AbstractEventsByPersistenceIdPublisher

buf, context, currSeqNo, fromSequenceNr, idle, init, journal, maxBufSize, persistenceId, receive, replay, replaying, self, timeForReplay, writeJournalPluginId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.stream.actor.ActorPublisher

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancelSelf, isActive, isCanceled, isCompleted, isErrorEmitted, onComplete, onCompleteThenStop, onError, onErrorThenStop, onNext, subscriptionTimeout, totalDemand

Methods inherited from interface akka.actor.Actor

postRestart, preRestart, preStart, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.persistence.query.journal.leveldb.DeliveryBuffer

deliverBuf

Methods inherited from interface akka.actor.ActorLogging

log

Constructor Detail

LiveEventsByPersistenceIdPublisher

public LiveEventsByPersistenceIdPublisher(java.lang.String persistenceId,
                                          long fromSequenceNr,
                                          long toSequenceNr,
                                          scala.concurrent.duration.FiniteDuration refreshInterval,
                                          int maxBufSize,
                                          java.lang.String writeJournalPluginId)

Method Detail

toSequenceNr

public long toSequenceNr()

Specified by:

toSequenceNr in class AbstractEventsByPersistenceIdPublisher

tickTask

public Cancellable tickTask()

postStop

public void postStop()

Description copied from interface: Actor

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

receiveInitialRequest

public void receiveInitialRequest()

Specified by:

receiveInitialRequest in class AbstractEventsByPersistenceIdPublisher

receiveIdleRequest

public void receiveIdleRequest()

Specified by:

receiveIdleRequest in class AbstractEventsByPersistenceIdPublisher

receiveRecoverySuccess

public void receiveRecoverySuccess(long highestSeqNr)

Specified by:

receiveRecoverySuccess in class AbstractEventsByPersistenceIdPublisher