public class CurrentEventsByTagPublisher extends AbstractEventsByTagPublisher
Constructor and Description |
---|
CurrentEventsByTagPublisher(java.lang.String tag,
long fromOffset,
long _toOffset,
int maxBufSize,
java.lang.String writeJournalPluginId) |
Modifier and Type | Method and Description |
---|---|
long |
_toOffset() |
void |
receiveIdleRequest() |
void |
receiveInitialRequest() |
void |
receiveRecoverySuccess(long highestSeqNr) |
long |
toOffset() |
currOffset, fromOffset, idle, init, journal, maxBufSize, receive, replay, replaying, tag, timeForReplay, 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 CurrentEventsByTagPublisher(java.lang.String tag, long fromOffset, long _toOffset, int maxBufSize, java.lang.String writeJournalPluginId)
public long _toOffset()
public long toOffset()
toOffset
in class AbstractEventsByTagPublisher
public void receiveInitialRequest()
receiveInitialRequest
in class AbstractEventsByTagPublisher
public void receiveIdleRequest()
receiveIdleRequest
in class AbstractEventsByTagPublisher
public void receiveRecoverySuccess(long highestSeqNr)
receiveRecoverySuccess
in class AbstractEventsByTagPublisher