Class CurrentEventsByPersistenceIdPublisher
- java.lang.Object
-
- akka.persistence.query.journal.leveldb.AbstractEventsByPersistenceIdPublisher
-
- akka.persistence.query.journal.leveldb.CurrentEventsByPersistenceIdPublisher
-
- All Implemented Interfaces:
Actor
,ActorLogging
,DeliveryBuffer<EventEnvelope>
,ActorPublisher<EventEnvelope>
public class CurrentEventsByPersistenceIdPublisher extends AbstractEventsByPersistenceIdPublisher
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
Nested classes/interfaces inherited from interface akka.stream.actor.ActorPublisher
ActorPublisher.Internal$
-
-
Constructor Summary
Constructors Constructor Description CurrentEventsByPersistenceIdPublisher(java.lang.String persistenceId, long fromSequenceNr, long toSeqNr, int maxBufSize, java.lang.String writeJournalPluginId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
receiveIdleRequest()
void
receiveInitialRequest()
void
receiveRecoverySuccess(long highestSeqNr)
long
toSeqNr()
void
toSeqNr_$eq(long x$1)
long
toSequenceNr()
-
Methods inherited from class akka.persistence.query.journal.leveldb.AbstractEventsByPersistenceIdPublisher
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, buf, buf_$eq, context, currSeqNo, currSeqNo_$eq, 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.actor.Actor
postRestart, postStop, preRestart, preStart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.stream.actor.ActorPublisher
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancelSelf, demand_$eq, isActive, isCanceled, isCompleted, isErrorEmitted, lifecycleState_$eq, onComplete, onCompleteThenStop, onError, onErrorThenStop, onNext, scheduledSubscriptionTimeout_$eq, subscriber_$eq, subscriptionTimeout, super$aroundPostRestart, super$aroundPostStop, super$aroundPreRestart, super$aroundPreStart, super$aroundReceive, totalDemand
-
Methods inherited from interface akka.persistence.query.journal.leveldb.DeliveryBuffer
deliverBuf
-
-
-
-
Method Detail
-
receiveIdleRequest
public void receiveIdleRequest()
- Specified by:
receiveIdleRequest
in classAbstractEventsByPersistenceIdPublisher
-
receiveInitialRequest
public void receiveInitialRequest()
- Specified by:
receiveInitialRequest
in classAbstractEventsByPersistenceIdPublisher
-
receiveRecoverySuccess
public void receiveRecoverySuccess(long highestSeqNr)
- Specified by:
receiveRecoverySuccess
in classAbstractEventsByPersistenceIdPublisher
-
toSeqNr
public long toSeqNr()
-
toSeqNr_$eq
public void toSeqNr_$eq(long x$1)
-
toSequenceNr
public long toSequenceNr()
- Specified by:
toSequenceNr
in classAbstractEventsByPersistenceIdPublisher
-
-