com.alibaba.schedulerx.worker.ha

类 AtLeastOnceDeliveryActor

java.lang.Object

akka.actor.UntypedActor

akka.persistence.UntypedPersistentActor

akka.persistence.UntypedPersistentActorWithAtLeastOnceDelivery

com.alibaba.schedulerx.worker.ha.AtLeastOnceDeliveryActor

所有已实现的接口:

akka.actor.Actor, akka.actor.Stash, akka.actor.StashFactory, akka.actor.StashSupport, akka.actor.UnrestrictedStash, akka.dispatch.RequiresMessageQueue<akka.dispatch.DequeBasedMessageQueueSemantics>, akka.persistence.AtLeastOnceDeliveryLike, akka.persistence.Eventsourced, akka.persistence.PersistenceIdentity, akka.persistence.PersistenceRecovery, akka.persistence.PersistenceStash, akka.persistence.Snapshotter

public class AtLeastOnceDeliveryActor
extends akka.persistence.UntypedPersistentActorWithAtLeastOnceDelivery

作者:

xiaomeng.hxm

嵌套类概要

从接口继承的嵌套类/接口 akka.persistence.Eventsourced

akka.persistence.Eventsourced.AsyncHandlerInvocation, akka.persistence.Eventsourced.AsyncHandlerInvocation$, akka.persistence.Eventsourced.PendingHandlerInvocation, akka.persistence.Eventsourced.ProcessingState, akka.persistence.Eventsourced.RecoveryTick, akka.persistence.Eventsourced.RecoveryTick$, akka.persistence.Eventsourced.StashingHandlerInvocation, akka.persistence.Eventsourced.StashingHandlerInvocation$, akka.persistence.Eventsourced.State

从接口继承的嵌套类/接口 akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

构造器概要

构造器

构造器和说明
AtLeastOnceDeliveryActor(int id)

方法概要

限定符和类型	方法和说明
void	onReceiveCommand(Object obj)
void	onReceiveRecover(Object obj)
String	persistenceId()

从类继承的方法 akka.persistence.UntypedPersistentActorWithAtLeastOnceDelivery

akka$persistence$AtLeastOnceDeliveryLike$_setter_$akka$persistence$AtLeastOnceDeliveryLike$$defaultMaxUnconfirmedMessages_$eq, akka$persistence$AtLeastOnceDeliveryLike$_setter_$akka$persistence$AtLeastOnceDeliveryLike$$defaultRedeliverInterval_$eq, akka$persistence$AtLeastOnceDeliveryLike$_setter_$akka$persistence$AtLeastOnceDeliveryLike$$defaultRedeliveryBurstLimit_$eq, akka$persistence$AtLeastOnceDeliveryLike$_setter_$akka$persistence$AtLeastOnceDeliveryLike$$defaultWarnAfterNumberOfUnconfirmedAttempts_$eq, akka$persistence$AtLeastOnceDeliveryLike$$defaultMaxUnconfirmedMessages, akka$persistence$AtLeastOnceDeliveryLike$$defaultRedeliverInterval, akka$persistence$AtLeastOnceDeliveryLike$$defaultRedeliveryBurstLimit, akka$persistence$AtLeastOnceDeliveryLike$$defaultWarnAfterNumberOfUnconfirmedAttempts, akka$persistence$AtLeastOnceDeliveryLike$$deliverySequenceNr_$eq, akka$persistence$AtLeastOnceDeliveryLike$$deliverySequenceNr, akka$persistence$AtLeastOnceDeliveryLike$$redeliverTask_$eq, akka$persistence$AtLeastOnceDeliveryLike$$redeliverTask, akka$persistence$AtLeastOnceDeliveryLike$$unconfirmed_$eq, akka$persistence$AtLeastOnceDeliveryLike$$unconfirmed, aroundPostStop, aroundPreRestart, aroundReceive, confirmDelivery, deliver, deliver, deliver, deliver, getDeliverySnapshot, maxUnconfirmedMessages, numberOfUnconfirmed, onReplaySuccess, redeliverInterval, redeliveryBurstLimit, setDeliverySnapshot, warnAfterNumberOfUnconfirmedAttempts

从类继承的方法 akka.persistence.UntypedPersistentActor

akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$extension_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$instanceId_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$internalStash_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$maxMessageBatchSize_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$pendingInvocations_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$persistingEvents_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$processingCommands_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$unstashFilterPredicate_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$writerUuid_$eq, akka$persistence$Eventsourced$$_lastSequenceNr_$eq, akka$persistence$Eventsourced$$_lastSequenceNr, akka$persistence$Eventsourced$$currentState_$eq, akka$persistence$Eventsourced$$currentState, akka$persistence$Eventsourced$$eventBatch_$eq, akka$persistence$Eventsourced$$eventBatch, akka$persistence$Eventsourced$$extension, akka$persistence$Eventsourced$$instanceId, akka$persistence$Eventsourced$$internalStash, akka$persistence$Eventsourced$$journalBatch_$eq, akka$persistence$Eventsourced$$journalBatch, akka$persistence$Eventsourced$$maxMessageBatchSize, akka$persistence$Eventsourced$$pendingInvocations, akka$persistence$Eventsourced$$pendingStashingPersistInvocations_$eq, akka$persistence$Eventsourced$$pendingStashingPersistInvocations, akka$persistence$Eventsourced$$persistingEvents, akka$persistence$Eventsourced$$processingCommands, akka$persistence$Eventsourced$$sequenceNr_$eq, akka$persistence$Eventsourced$$sequenceNr, akka$persistence$Eventsourced$$unstashFilterPredicate, akka$persistence$Eventsourced$$writeInProgress_$eq, akka$persistence$Eventsourced$$writeInProgress, akka$persistence$Eventsourced$$writerUuid, aroundPostRestart, aroundPreStart, clearStash, createStash, deferAsync, deferAsync, deleteMessages, deleteSnapshot, deleteSnapshots, internalStashOverflowStrategy, journal, journalPluginId, lastSequenceNr, loadSnapshot, mailbox, onPersistFailure, onPersistRejected, onReceive, onRecoveryFailure, persist, persist, persist, persist, persistAll, persistAll, persistAllAsync, persistAllAsync, persistAsync, persistAsync, persistAsync, postStop, prepend, preRestart, receiveCommand, receiveRecover, recovery, recoveryFinished, recoveryRunning, saveSnapshot, snapshotPluginId, snapshotSequenceNr, snapshotStore, snapshotterId, stash, unhandled, unstash, unstashAll, unstashAll

从类继承的方法 akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, getContext, getSelf, getSender, postRestart, preStart, receive, self, sender, supervisorStrategy

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 akka.persistence.Eventsourced

akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$extension_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$instanceId_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$internalStash_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$maxMessageBatchSize_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$pendingInvocations_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$persistingEvents_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$processingCommands_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$unstashFilterPredicate_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$writerUuid_$eq, akka$persistence$Eventsourced$$_lastSequenceNr_$eq, akka$persistence$Eventsourced$$_lastSequenceNr, akka$persistence$Eventsourced$$currentState_$eq, akka$persistence$Eventsourced$$currentState, akka$persistence$Eventsourced$$eventBatch_$eq, akka$persistence$Eventsourced$$eventBatch, akka$persistence$Eventsourced$$extension, akka$persistence$Eventsourced$$instanceId, akka$persistence$Eventsourced$$internalStash, akka$persistence$Eventsourced$$journalBatch_$eq, akka$persistence$Eventsourced$$journalBatch, akka$persistence$Eventsourced$$maxMessageBatchSize, akka$persistence$Eventsourced$$pendingInvocations, akka$persistence$Eventsourced$$pendingStashingPersistInvocations_$eq, akka$persistence$Eventsourced$$pendingStashingPersistInvocations, akka$persistence$Eventsourced$$persistingEvents, akka$persistence$Eventsourced$$processingCommands, akka$persistence$Eventsourced$$sequenceNr_$eq, akka$persistence$Eventsourced$$sequenceNr, akka$persistence$Eventsourced$$unstashFilterPredicate, akka$persistence$Eventsourced$$writeInProgress_$eq, akka$persistence$Eventsourced$$writeInProgress, akka$persistence$Eventsourced$$writerUuid, aroundPostRestart, aroundPreStart, deferAsync, deleteMessages, journal, lastSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, persist, persist, persistAll, persistAllAsync, persistAsync, persistAsync, receiveCommand, receiveRecover, recoveryFinished, recoveryRunning, snapshotSequenceNr, snapshotStore, snapshotterId, unhandled, unstashAll

从接口继承的方法 akka.persistence.Snapshotter

deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot

从接口继承的方法 akka.persistence.PersistenceStash

internalStashOverflowStrategy

从接口继承的方法 akka.actor.Actor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preStart, receive, self, sender, supervisorStrategy

从接口继承的方法 akka.actor.StashSupport

akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, context, mailbox, prepend, self, stash, unstash, unstashAll

从接口继承的方法 akka.actor.StashFactory

createStash

从接口继承的方法 akka.persistence.PersistenceIdentity

journalPluginId, snapshotPluginId

从接口继承的方法 akka.persistence.PersistenceRecovery

recovery

构造器详细资料

AtLeastOnceDeliveryActor

public AtLeastOnceDeliveryActor(int id)

方法详细资料

persistenceId

public String persistenceId()

onReceiveCommand

public void onReceiveCommand(Object obj)

指定者:

onReceiveCommand 在类中 akka.persistence.UntypedPersistentActor

onReceiveRecover

public void onReceiveRecover(Object obj)
                      throws Throwable

指定者:

onReceiveRecover 在类中 akka.persistence.UntypedPersistentActor

抛出:

Throwable