Class AbstractEventsByTagPublisher
- java.lang.Object
-
- akka.persistence.query.journal.leveldb.AbstractEventsByTagPublisher
-
- All Implemented Interfaces:
Actor
,ActorLogging
,DeliveryBuffer<EventEnvelope>
,ActorPublisher<EventEnvelope>
- Direct Known Subclasses:
CurrentEventsByTagPublisher
,LiveEventsByTagPublisher
public abstract class AbstractEventsByTagPublisher extends java.lang.Object implements ActorPublisher<EventEnvelope>, DeliveryBuffer<EventEnvelope>, ActorLogging
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 AbstractEventsByTagPublisher(java.lang.String tag, long fromOffset, int maxBufSize, java.lang.String writeJournalPluginId)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.scala.collection.immutable.Vector<EventEnvelope>
buf()
void
buf_$eq(scala.collection.immutable.Vector<EventEnvelope> x$1)
ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.long
currOffset()
void
currOffset_$eq(long x$1)
long
fromOffset()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
idle()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
init()
ActorRef
journal()
int
maxBufSize()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: 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.java.lang.String
tag()
boolean
timeForReplay()
abstract long
toOffset()
java.lang.String
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, postStop, 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
-
-
-
-
Method Detail
-
akka$actor$Actor$_setter_$context_$eq
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
akka$actor$Actor$_setter_$self_$eq
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
akka$actor$Actor$_setter_$self_$eq
in interfaceActor
- Parameters:
x$1
- (undocumented)
-
buf
public scala.collection.immutable.Vector<EventEnvelope> buf()
- Specified by:
buf
in interfaceDeliveryBuffer<EventEnvelope>
-
buf_$eq
public void buf_$eq(scala.collection.immutable.Vector<EventEnvelope> x$1)
- Specified by:
buf_$eq
in interfaceDeliveryBuffer<EventEnvelope>
-
context
public ActorContext context()
Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.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 aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
currOffset
public long currOffset()
-
currOffset_$eq
public void currOffset_$eq(long x$1)
-
fromOffset
public long fromOffset()
-
idle
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> idle()
-
init
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> init()
-
journal
public ActorRef journal()
-
maxBufSize
public int maxBufSize()
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
-
receiveIdleRequest
public abstract void receiveIdleRequest()
-
receiveInitialRequest
public abstract void receiveInitialRequest()
-
receiveRecoverySuccess
public abstract void receiveRecoverySuccess(long highestSeqNr)
-
replay
public void replay()
-
replaying
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> replaying(int limit)
-
self
public final ActorRef self()
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
-
tag
public java.lang.String tag()
-
timeForReplay
public boolean timeForReplay()
-
toOffset
public abstract long toOffset()
-
writeJournalPluginId
public java.lang.String writeJournalPluginId()
-
-