public class AllPersistenceIdsPublisher extends java.lang.Object implements akka.stream.actor.ActorPublisher<java.lang.String>, DeliveryBuffer<java.lang.String>, akka.actor.ActorLogging
Constructor and Description |
---|
AllPersistenceIdsPublisher(boolean liveQuery,
int maxBufSize,
java.lang.String writeJournalPluginId) |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
active() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
init() |
akka.actor.ActorRef |
journal() |
static akka.actor.Props |
props(boolean liveQuery,
int maxBufSize,
java.lang.String writeJournalPluginId) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
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 AllPersistenceIdsPublisher(boolean liveQuery, int maxBufSize, java.lang.String writeJournalPluginId)
public static akka.actor.Props props(boolean liveQuery, int maxBufSize, java.lang.String writeJournalPluginId)
public akka.actor.ActorRef journal()
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 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> active()