akka.camel.internal

Class ActivationTracker.ActivationStateMachine

java.lang.Object

akka.camel.internal.ActivationTracker.ActivationStateMachine

Enclosing class:

ActivationTracker

public class ActivationTracker.ActivationStateMachine
extends java.lang.Object

A state machine that keeps track of the endpoint activation status of an actor.

Constructor Summary

Constructors

Constructor and Description
ActivationStateMachine()

Method Summary

Modifier and Type	Method and Description
scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit>	activated(scala.collection.immutable.List<ActorRef> currentAwaitingDeActivation) Activated state.
scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit>	deactivated() De-activated state
scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit>	failedToActivate(java.lang.Throwable cause) Failed to activate state
scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit>	failedToDeActivate(java.lang.Throwable cause) Failed to de-activate state
scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit>	notActivated() Not activated state
scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit>	receive()

Methods inherited from class java.lang.Object

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

Constructor Detail

ActivationStateMachine

public ActivationStateMachine()

Method Detail

receive

public scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit> receive()

notActivated

public scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit> notActivated()

Not activated state

Returns:

a partial function that handles messages in the 'not activated' state

activated

public scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit> activated(scala.collection.immutable.List<ActorRef> currentAwaitingDeActivation)

Activated state.

Parameters:

currentAwaitingDeActivation - the current ActorRefs awaiting de-activation

Returns:

a partial function that handles messages in the 'activated' state

deactivated

public scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit> deactivated()

De-activated state

Returns:

a partial function that handles messages in the 'de-activated' state

failedToActivate

public scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit> failedToActivate(java.lang.Throwable cause)

Failed to activate state

Parameters:

cause - the cause for the failure

Returns:

a partial function that handles messages in 'failed to activate' state

failedToDeActivate

public scala.PartialFunction<ActivationProtocol.ActivationMessage,scala.runtime.BoxedUnit> failedToDeActivate(java.lang.Throwable cause)

Failed to de-activate state

Parameters:

cause - the cause for the failure

Returns:

a partial function that handles messages in 'failed to de-activate' state