Package akka.persistence.query.journal.leveldb

Class LiveEventsByTagPublisher

java.lang.Object

akka.persistence.query.journal.leveldb.AbstractEventsByTagPublisher

akka.persistence.query.journal.leveldb.LiveEventsByTagPublisher

All Implemented Interfaces:

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

public class LiveEventsByTagPublisher
extends AbstractEventsByTagPublisher

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
LiveEventsByTagPublisher(java.lang.String tag, long fromOffset, long toOffset, scala.concurrent.duration.FiniteDuration refreshInterval, int maxBufSize, java.lang.String writeJournalPluginId)

Method Summary

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

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

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, buf, buf_$eq, context, currOffset, currOffset_$eq, 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.actor.Actor

postRestart, 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

LiveEventsByTagPublisher

public LiveEventsByTagPublisher(java.lang.String tag,
                                long fromOffset,
                                long toOffset,
                                scala.concurrent.duration.FiniteDuration refreshInterval,
                                int maxBufSize,
                                java.lang.String writeJournalPluginId)

Method Detail

postStop

public void postStop()

Description copied from interface: Actor

User overridable callback.

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

receiveIdleRequest

public void receiveIdleRequest()

Specified by:

receiveIdleRequest in class AbstractEventsByTagPublisher

receiveInitialRequest

public void receiveInitialRequest()

Specified by:

receiveInitialRequest in class AbstractEventsByTagPublisher

receiveRecoverySuccess

public void receiveRecoverySuccess(long highestSeqNr)

Specified by:

receiveRecoverySuccess in class AbstractEventsByTagPublisher

tickTask

public Cancellable tickTask()

toOffset

public long toOffset()

Specified by:

toOffset in class AbstractEventsByTagPublisher