public abstract class AbstractEventsByPersistenceIdPublisher extends java.lang.Object implements ActorPublisher<EventEnvelope>, DeliveryBuffer<EventEnvelope>, ActorLogging
ActorPublisher.Internal$
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
AbstractEventsByPersistenceIdPublisher(java.lang.String persistenceId,
long fromSequenceNr,
int maxBufSize,
java.lang.String writeJournalPluginId) |
Modifier and Type | Method and Description |
---|---|
scala.collection.immutable.Vector<EventEnvelope> |
buf() |
ActorContext |
context()
Stores the context for this actor, including self, and sender.
|
long |
currSeqNo() |
long |
fromSequenceNr() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
idle() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
init() |
ActorRef |
journal() |
int |
maxBufSize() |
java.lang.String |
persistenceId() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function
with the actor logic.
|
abstract void |
receiveIdleRequest() |
abstract void |
receiveInitialRequest() |
abstract void |
receiveRecoverySuccess(long highestSeqNr) |
void |
replay() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
replaying(int limit) |
ActorRef |
self()
The 'self' field holds the ActorRef for this actor.
|
boolean |
timeForReplay() |
abstract long |
toSequenceNr() |
java.lang.String |
writeJournalPluginId() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancelSelf, isActive, isCanceled, isCompleted, isErrorEmitted, onComplete, onCompleteThenStop, onError, onErrorThenStop, onNext, subscriptionTimeout, totalDemand
postRestart, postStop, preRestart, preStart, sender, supervisorStrategy, unhandled
deliverBuf
log
public AbstractEventsByPersistenceIdPublisher(java.lang.String persistenceId, long fromSequenceNr, int maxBufSize, java.lang.String writeJournalPluginId)
public scala.collection.immutable.Vector<EventEnvelope> buf()
buf
in interface DeliveryBuffer<EventEnvelope>
public ActorContext context()
Actor
forward
.
WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API. getContext
returns a
UntypedActorContext
, which is the Java API of the actor
context.
public final ActorRef self()
Actor
self ! message
public java.lang.String persistenceId()
public long fromSequenceNr()
public int maxBufSize()
public java.lang.String writeJournalPluginId()
public ActorRef journal()
public long currSeqNo()
public abstract long toSequenceNr()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
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)