akka.remote.transport
Class ProtocolStateActor

java.lang.Object
  akka.remote.transport.ProtocolStateActor

All Implemented Interfaces:

Actor, ActorLogging, FSM<ProtocolStateActor.AssociationState,ProtocolStateActor.ProtocolStateData>, RequiresMessageQueue<UnboundedMessageQueueSemantics>, Listeners

public class ProtocolStateActor
extends java.lang.Object
implements Actor, FSM<ProtocolStateActor.AssociationState,ProtocolStateActor.ProtocolStateData>, RequiresMessageQueue<UnboundedMessageQueueSemantics>

Nested Class Summary

static class	ProtocolStateActor.AssociatedWaitHandler
static class	ProtocolStateActor.AssociatedWaitHandler$
static interface	ProtocolStateActor.AssociationState
static class	ProtocolStateActor.Closed$
static class	ProtocolStateActor.ForbiddenUidReason$
static class	ProtocolStateActor.Handle
static class	ProtocolStateActor.Handle$
static class	ProtocolStateActor.HandleListenerRegistered
static class	ProtocolStateActor.HandleListenerRegistered$
static class	ProtocolStateActor.HandshakeTimer$
static class	ProtocolStateActor.HeartbeatTimer$
static class	ProtocolStateActor.InboundUnassociated
static class	ProtocolStateActor.InboundUnassociated$
static interface	ProtocolStateActor.InitialProtocolStateData
static class	ProtocolStateActor.ListenerReady
static class	ProtocolStateActor.ListenerReady$
static class	ProtocolStateActor.Open$
static class	ProtocolStateActor.OutboundUnassociated
static class	ProtocolStateActor.OutboundUnassociated$
static class	ProtocolStateActor.OutboundUnderlyingAssociated
static class	ProtocolStateActor.OutboundUnderlyingAssociated$
static interface	ProtocolStateActor.ProtocolStateData
static class	ProtocolStateActor.TimeoutReason
static class	ProtocolStateActor.TimeoutReason$
static class	ProtocolStateActor.WaitHandshake$

Nested classes/interfaces inherited from interface akka.actor.FSM

FSM.$minus$greater$, FSM.CurrentState<S>, FSM.CurrentState$, FSM.Event<D>, FSM.Event$, FSM.Failure, FSM.Failure$, FSM.LogEntry<S,D>, FSM.LogEntry$, FSM.Normal$, FSM.NullFunction$, FSM.Reason, FSM.Shutdown$, FSM.State<S,D>, FSM.State$, FSM.StateTimeout$, FSM.StopEvent<S,D>, FSM.StopEvent$, FSM.SubscribeTransitionCallBack, FSM.SubscribeTransitionCallBack$, FSM.TimeoutMarker, FSM.TimeoutMarker$, FSM.Timer, FSM.Timer$, FSM.TransformHelper, FSM.Transition<S>, FSM.Transition$, FSM.UnsubscribeTransitionCallBack, FSM.UnsubscribeTransitionCallBack$

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$

Constructor Summary

ProtocolStateActor(HandshakeInfo handshakeInfo, Address remoteAddress, scala.concurrent.Promise<AssociationHandle> statusPromise, Transport transport, AkkaProtocolSettings settings, AkkaPduCodec codec, FailureDetector failureDetector, scala.Option<java.lang.Object> refuseUid)

ProtocolStateActor(HandshakeInfo handshakeInfo, AssociationHandle wrappedHandle, Transport.AssociationEventListener associationListener, AkkaProtocolSettings settings, AkkaPduCodec codec, FailureDetector failureDetector)

ProtocolStateActor(ProtocolStateActor.InitialProtocolStateData initialData, HandshakeInfo localHandshakeInfo, scala.Option<java.lang.Object> refuseUid, AkkaProtocolSettings settings, AkkaPduCodec codec, FailureDetector failureDetector)

Method Summary

java.lang.String	handshakeTimerKey()
static Props	inboundProps(HandshakeInfo handshakeInfo, AssociationHandle wrappedHandle, Transport.AssociationEventListener associationListener, AkkaProtocolSettings settings, AkkaPduCodec codec, FailureDetector failureDetector)
Address	localAddress()
protected void	logTermination(FSM.Reason reason) By default FSM.Failure is logged at error level and other reason types are not logged.
static Props	outboundProps(HandshakeInfo handshakeInfo, Address remoteAddress, scala.concurrent.Promise<AssociationHandle> statusPromise, Transport transport, AkkaProtocolSettings settings, AkkaPduCodec codec, FailureDetector failureDetector, scala.Option<java.lang.Object> refuseUid)
void	postStop() User overridable callback.

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.actor.FSM

applyState, cancelTimer, currentState, debugEvent, Event, generation, handleEvent, handleEventDefault, handleTransition, initialize, isStateTimerActive, isTimerActive, makeTransition, nextState, nextStateData, onTermination, onTransition, processEvent, processMsg, receive, register, setStateTimeout, setTimer, startWith, stateData, stateFunctions, stateName, StateTimeout, stateTimeouts, stay, stop, stop, stop, StopEvent, terminate, terminateEvent, timeoutFuture, timerGen, timers, total2pf, transform, transitionEvent, when, whenUnhandled

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.routing.Listeners

gossip, listenerManagement, listeners

Methods inherited from interface akka.actor.ActorLogging

_log, log

Constructor Detail

ProtocolStateActor

public ProtocolStateActor(ProtocolStateActor.InitialProtocolStateData initialData,
                          HandshakeInfo localHandshakeInfo,
                          scala.Option<java.lang.Object> refuseUid,
                          AkkaProtocolSettings settings,
                          AkkaPduCodec codec,
                          FailureDetector failureDetector)

ProtocolStateActor

public ProtocolStateActor(HandshakeInfo handshakeInfo,
                          Address remoteAddress,
                          scala.concurrent.Promise<AssociationHandle> statusPromise,
                          Transport transport,
                          AkkaProtocolSettings settings,
                          AkkaPduCodec codec,
                          FailureDetector failureDetector,
                          scala.Option<java.lang.Object> refuseUid)

ProtocolStateActor

public ProtocolStateActor(HandshakeInfo handshakeInfo,
                          AssociationHandle wrappedHandle,
                          Transport.AssociationEventListener associationListener,
                          AkkaProtocolSettings settings,
                          AkkaPduCodec codec,
                          FailureDetector failureDetector)

Method Detail

outboundProps

public static Props outboundProps(HandshakeInfo handshakeInfo,
                                  Address remoteAddress,
                                  scala.concurrent.Promise<AssociationHandle> statusPromise,
                                  Transport transport,
                                  AkkaProtocolSettings settings,
                                  AkkaPduCodec codec,
                                  FailureDetector failureDetector,
                                  scala.Option<java.lang.Object> refuseUid)

inboundProps

public static Props inboundProps(HandshakeInfo handshakeInfo,
                                 AssociationHandle wrappedHandle,
                                 Transport.AssociationEventListener associationListener,
                                 AkkaProtocolSettings settings,
                                 AkkaPduCodec codec,
                                 FailureDetector failureDetector)

localAddress

public Address localAddress()

handshakeTimerKey

public java.lang.String handshakeTimerKey()

postStop

public void postStop()

Description copied from interface: Actor

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

Specified by:

postStop in interface Actor

Specified by:

postStop in interface FSM<ProtocolStateActor.AssociationState,ProtocolStateActor.ProtocolStateData>

logTermination

protected void logTermination(FSM.Reason reason)

Description copied from interface: FSM

By default FSM.Failure is logged at error level and other reason types are not logged. It is possible to override this behavior.

Specified by:

logTermination in interface FSM<ProtocolStateActor.AssociationState,ProtocolStateActor.ProtocolStateData>

Parameters:

reason - (undocumented)