public abstract class AbstractEventsByTagPublisher extends java.lang.Object implements akka.stream.actor.ActorPublisher<EventEnvelope>, DeliveryBuffer<EventEnvelope>, akka.actor.ActorLogging
Constructor and Description |
---|
AbstractEventsByTagPublisher(java.lang.String tag,
long fromOffset,
int maxBufSize,
java.lang.String writeJournalPluginId) |
Modifier and Type | Method and Description |
---|---|
long |
currOffset() |
long |
fromOffset() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
idle() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
init() |
akka.actor.ActorRef |
journal() |
int |
maxBufSize() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
abstract void |
receiveIdleRequest() |
abstract void |
receiveInitialRequest() |
abstract void |
receiveRecoverySuccess(long highestSeqNr) |
void |
replay() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
replaying(int limit) |
java.lang.String |
tag() |
boolean |
timeForReplay() |
abstract long |
toOffset() |
java.lang.String |
writeJournalPluginId() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$stream$actor$ActorPublisher$_setter_$akka$stream$actor$ActorPublisher$$state_$eq, akka$stream$actor$ActorPublisher$$demand_$eq, akka$stream$actor$ActorPublisher$$demand, akka$stream$actor$ActorPublisher$$lifecycleState_$eq, akka$stream$actor$ActorPublisher$$lifecycleState, akka$stream$actor$ActorPublisher$$scheduledSubscriptionTimeout_$eq, akka$stream$actor$ActorPublisher$$scheduledSubscriptionTimeout, akka$stream$actor$ActorPublisher$$state, akka$stream$actor$ActorPublisher$$subscriber_$eq, akka$stream$actor$ActorPublisher$$subscriber, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, isActive, isCanceled, isCompleted, isErrorEmitted, onComplete, onCompleteThenStop, onError, onErrorThenStop, onNext, subscriptionTimeout, totalDemand
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
buf, deliverBuf
public AbstractEventsByTagPublisher(java.lang.String tag, long fromOffset, int maxBufSize, java.lang.String writeJournalPluginId)
public java.lang.String tag()
public long fromOffset()
public int maxBufSize()
public java.lang.String writeJournalPluginId()
public akka.actor.ActorRef journal()
public long currOffset()
public abstract long toOffset()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> init()
public abstract void receiveInitialRequest()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> idle()
public abstract void receiveIdleRequest()
public boolean timeForReplay()
public void replay()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> replaying(int limit)
public abstract void receiveRecoverySuccess(long highestSeqNr)