Package akka.persistence.query.journal.leveldb

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

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

Constructor Detail

CurrentEventsByPersistenceIdPublisher

public CurrentEventsByPersistenceIdPublisher(java.lang.String persistenceId,
                                             long fromSequenceNr,
                                             long toSeqNr,
                                             int maxBufSize,
                                             java.lang.String writeJournalPluginId)

Method Detail

receiveIdleRequest

public void receiveIdleRequest()

Specified by:

receiveIdleRequest in class AbstractEventsByPersistenceIdPublisher

receiveInitialRequest

public void receiveInitialRequest()

Specified by:

receiveInitialRequest in class AbstractEventsByPersistenceIdPublisher

receiveRecoverySuccess

public void receiveRecoverySuccess(long highestSeqNr)

Specified by:

receiveRecoverySuccess in class AbstractEventsByPersistenceIdPublisher

toSeqNr

public long toSeqNr()

toSeqNr_$eq

public void toSeqNr_$eq(long x$1)

toSequenceNr

public long toSequenceNr()

Specified by:

toSequenceNr in class AbstractEventsByPersistenceIdPublisher