public abstract class AbstractEventsByPersistenceIdPublisher extends java.lang.Object implements akka.stream.actor.ActorPublisher<EventEnvelope>, DeliveryBuffer<EventEnvelope>, akka.actor.ActorLogging
Constructor and Description |
---|
AbstractEventsByPersistenceIdPublisher(java.lang.String persistenceId,
long fromSequenceNr,
int maxBufSize,
java.lang.String writeJournalPluginId) |
Modifier and Type | Method and Description |
---|---|
long |
currSeqNo() |
long |
fromSequenceNr() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
idle() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
init() |
akka.actor.ActorRef |
journal() |
int |
maxBufSize() |
java.lang.String |
persistenceId() |
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) |
boolean |
timeForReplay() |
abstract long |
toSequenceNr() |
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 AbstractEventsByPersistenceIdPublisher(java.lang.String persistenceId, long fromSequenceNr, int maxBufSize, java.lang.String writeJournalPluginId)
public java.lang.String persistenceId()
public long fromSequenceNr()
public int maxBufSize()
public java.lang.String writeJournalPluginId()
public akka.actor.ActorRef journal()
public long currSeqNo()
public abstract long toSequenceNr()
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)