akka.persistence.query.journal.leveldb

Class CurrentEventsByTagPublisher

java.lang.Object

akka.persistence.query.journal.leveldb.AbstractEventsByTagPublisher

akka.persistence.query.journal.leveldb.CurrentEventsByTagPublisher

All Implemented Interfaces:

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

public class CurrentEventsByTagPublisher
extends AbstractEventsByTagPublisher

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
CurrentEventsByTagPublisher(java.lang.String tag, long fromOffset, long _toOffset, int maxBufSize, java.lang.String writeJournalPluginId)

Method Summary

Modifier and Type	Method and Description
long	_toOffset()
void	receiveIdleRequest()
void	receiveInitialRequest()
void	receiveRecoverySuccess(long highestSeqNr)
long	toOffset()

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

buf, context, currOffset, fromOffset, idle, init, journal, maxBufSize, receive, replay, replaying, self, tag, 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, postStop, 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

CurrentEventsByTagPublisher

public CurrentEventsByTagPublisher(java.lang.String tag,
                                   long fromOffset,
                                   long _toOffset,
                                   int maxBufSize,
                                   java.lang.String writeJournalPluginId)

Method Detail

_toOffset

public long _toOffset()

toOffset

public long toOffset()

Specified by:

toOffset in class AbstractEventsByTagPublisher

receiveInitialRequest

public void receiveInitialRequest()

Specified by:

receiveInitialRequest in class AbstractEventsByTagPublisher

receiveIdleRequest

public void receiveIdleRequest()

Specified by:

receiveIdleRequest in class AbstractEventsByTagPublisher

receiveRecoverySuccess

public void receiveRecoverySuccess(long highestSeqNr)

Specified by:

receiveRecoverySuccess in class AbstractEventsByTagPublisher