Package akka.contrib.pattern
Class ReliableProxy
- java.lang.Object
-
- akka.contrib.pattern.ReliableProxy
-
- All Implemented Interfaces:
Actor
,ActorLogging
,FSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
,LoggingFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
,ReliableProxyDebugLogging
,Listeners
public class ReliableProxy extends java.lang.Object implements Actor, LoggingFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>, ReliableProxyDebugLogging
Deprecated.Use AtLeastOnceDelivery instead. Since 2.5.0.Reset backoff interval.This and nextBackoff are meant to be implemented by subclasses.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ReliableProxy.Active$
Deprecated.static class
ReliableProxy.Connecting$
Deprecated.static class
ReliableProxy.Idle$
Deprecated.static class
ReliableProxy.Message
Deprecated.static class
ReliableProxy.Message$
Deprecated.static class
ReliableProxy.ProxyTerminated
Deprecated.static class
ReliableProxy.ProxyTerminated$
Deprecated.static class
ReliableProxy.Receiver
Deprecated.static interface
ReliableProxy.State
Deprecated.static class
ReliableProxy.TargetChanged
Deprecated.static class
ReliableProxy.TargetChanged$
Deprecated.static class
ReliableProxy.Unsent
Deprecated.static class
ReliableProxy.Unsent$
Deprecated.-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
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.SilentState<S,D>, FSM.State$, FSM.StateTimeout$, FSM.StopEvent<S,D>, FSM.StopEvent$, FSM.SubscribeTransitionCallBack, FSM.SubscribeTransitionCallBack$, FSM.Timer, FSM.Timer$, FSM.TransformHelper, FSM.Transition<S>, FSM.Transition$, FSM.UnsubscribeTransitionCallBack, FSM.UnsubscribeTransitionCallBack$
-
-
Constructor Summary
Constructors Constructor Description ReliableProxy(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.Option<scala.concurrent.duration.FiniteDuration> reconnectAfter, scala.Option<java.lang.Object> maxConnectAttempts)
Deprecated.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description FSM.$minus$greater$
$minus$greater()
Deprecated.This extractor is just convenience for matching a (S, S) pair, including a reminder what the new state is.static ReliableProxy.Active$
active()
Deprecated.protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Deprecated.protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Deprecated.The 'self' field holds the ActorRef for this actor.protected void
akka$actor$FSM$_setter_$Event_$eq(FSM.Event$ x$1)
Deprecated.protected void
akka$actor$FSM$_setter_$StateTimeout_$eq(FSM.StateTimeout$ x$1)
Deprecated.This case object is received in case of a state timeout.protected void
akka$actor$FSM$_setter_$StopEvent_$eq(FSM.StopEvent$ x$1)
Deprecated.protected void
akka$actor$LoggingFSM$_setter_$debugEvent_$eq(boolean x$1)
Deprecated.protected void
akka$contrib$pattern$ReliableProxyDebugLogging$_setter_$debug_$eq(boolean x$1)
Deprecated.protected void
akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
Deprecated.int
attemptedReconnects()
Deprecated.void
attemptedReconnects_$eq(int x$1)
Deprecated.static int
compare(int a, int b)
Deprecated.ActorContext
context()
Deprecated.Scala API: Stores the context for this actor, including self, and sender.void
createTunnel(ActorRef target)
Deprecated.int
currentSerial()
Deprecated.void
currentSerial_$eq(int x$1)
Deprecated.ActorRef
currentTarget()
Deprecated.void
currentTarget_$eq(ActorRef x$1)
Deprecated.boolean
debug()
Deprecated.boolean
debugEvent()
Deprecated.scala.concurrent.duration.FiniteDuration
defaultConnectInterval()
Deprecated.FSM.Event$
Event()
Deprecated.static ReliableProxy.Idle$
idle()
Deprecated.ReliableProxy.Connecting$
initialState()
Deprecated.int
lastAckSerial()
Deprecated.void
lastAckSerial_$eq(int x$1)
Deprecated.protected java.util.Set<ActorRef>
listeners()
Deprecated.void
logResend(int size)
Deprecated.scala.concurrent.duration.FiniteDuration
nextBackoff()
Deprecated.Returns the next retry interval duration.int
nextSerial()
Deprecated.void
postStop()
Deprecated.User overridable callback.static Props
props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter)
Deprecated.Props with no reconnections.static Props
props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.concurrent.duration.FiniteDuration reconnectAfter)
Deprecated.Props with no limit on reconnections.static Props
props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.concurrent.duration.FiniteDuration reconnectAfter, int maxReconnects)
Deprecated.Java API Props.static Props
props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.Option<scala.concurrent.duration.FiniteDuration> reconnectAfter, scala.Option<java.lang.Object> maxReconnects)
Deprecated.static Props
receiver(ActorRef target, int currentSerial)
Deprecated.static ReliableProxy.Connecting$
reconnecting()
Deprecated.java.lang.String
reconnectTimer()
Deprecated.scala.collection.immutable.Vector<ReliableProxy.Message>
resend(scala.collection.immutable.Vector<ReliableProxy.Message> q)
Deprecated.java.lang.String
resendTimer()
Deprecated.void
resetBackoff()
Deprecated.Reset backoff interval.long
retryGateClosedFor()
Deprecated.void
scheduleReconnectTick()
Deprecated.void
scheduleTick()
Deprecated.ActorRef
self()
Deprecated.The 'self' field holds the ActorRef for this actor.ReliableProxy.Message
send(java.lang.Object msg, ActorRef snd)
Deprecated.FSM.StateTimeout$
StateTimeout()
Deprecated.This case object is received in case of a state timeout.FSM.StopEvent$
StopEvent()
Deprecated.OneForOneStrategy
supervisorStrategy()
Deprecated.User overridable definition the strategy to use for supervising child actors.FSM.State<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
terminated()
Deprecated.ActorRef
tunnel()
Deprecated.void
tunnel_$eq(ActorRef x$1)
Deprecated.scala.collection.immutable.Vector<ReliableProxy.Message>
updateSerial(scala.collection.immutable.Vector<ReliableProxy.Message> q)
Deprecated.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, preStart, sender, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.actor.FSM
applyState, cancelTimer, currentState_$eq, generation_$eq, handleEvent_$eq, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextState_$eq, nextStateData, onTermination, onTransition, processMsg, receive, register, setStateTimeout, setTimer, setTimer$default$4, startWith, startWith$default$3, stateData, stateName, stay, stop, stop, stop, super$postStop, terminate, terminateEvent_$eq, timeoutFuture_$eq, total2pf, transform, transitionEvent_$eq, when, when$default$2, whenUnhandled
-
Methods inherited from interface akka.routing.Listeners
gossip, gossip$default$2, listenerManagement
-
Methods inherited from interface akka.actor.LoggingFSM
advance, full_$eq, getLog, logDepth, pos_$eq, processEvent, super$processEvent
-
Methods inherited from interface akka.contrib.pattern.ReliableProxyDebugLogging
addSelf, enabled, logDebug, logDebug
-
-
-
-
Constructor Detail
-
ReliableProxy
public ReliableProxy(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.Option<scala.concurrent.duration.FiniteDuration> reconnectAfter, scala.Option<java.lang.Object> maxConnectAttempts)
Deprecated.
-
-
Method Detail
-
props
public static Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.Option<scala.concurrent.duration.FiniteDuration> reconnectAfter, scala.Option<java.lang.Object> maxReconnects)
Deprecated.
-
props
public static Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.concurrent.duration.FiniteDuration reconnectAfter, int maxReconnects)
Deprecated.Java API Props. Arguments are detailed in theReliableProxy
constructor.- Parameters:
targetPath
- (undocumented)retryAfter
- (undocumented)reconnectAfter
- (undocumented)maxReconnects
- (undocumented)- Returns:
- (undocumented)
-
props
public static Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.concurrent.duration.FiniteDuration reconnectAfter)
Deprecated.Props with no limit on reconnections. Arguments are detailed in theReliableProxy
constructor.- Parameters:
targetPath
- (undocumented)retryAfter
- (undocumented)reconnectAfter
- (undocumented)- Returns:
- (undocumented)
-
props
public static Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter)
Deprecated.Props with no reconnections. Arguments are detailed in theReliableProxy
constructor.- Parameters:
targetPath
- (undocumented)retryAfter
- (undocumented)- Returns:
- (undocumented)
-
compare
public static int compare(int a, int b)
Deprecated.
-
idle
public static ReliableProxy.Idle$ idle()
Deprecated.
-
active
public static ReliableProxy.Active$ active()
Deprecated.
-
reconnecting
public static ReliableProxy.Connecting$ reconnecting()
Deprecated.
-
debug
public boolean debug()
Deprecated.- Specified by:
debug
in interfaceReliableProxyDebugLogging
-
akka$contrib$pattern$ReliableProxyDebugLogging$_setter_$debug_$eq
protected void akka$contrib$pattern$ReliableProxyDebugLogging$_setter_$debug_$eq(boolean x$1)
Deprecated.- Specified by:
akka$contrib$pattern$ReliableProxyDebugLogging$_setter_$debug_$eq
in interfaceReliableProxyDebugLogging
-
debugEvent
public boolean debugEvent()
Deprecated.- Specified by:
debugEvent
in interfaceFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
- Specified by:
debugEvent
in interfaceLoggingFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
-
akka$actor$LoggingFSM$_setter_$debugEvent_$eq
protected void akka$actor$LoggingFSM$_setter_$debugEvent_$eq(boolean x$1)
Deprecated.- Specified by:
akka$actor$LoggingFSM$_setter_$debugEvent_$eq
in interfaceLoggingFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
-
Event
public FSM.Event$ Event()
Deprecated.- Specified by:
Event
in interfaceFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
-
StopEvent
public FSM.StopEvent$ StopEvent()
Deprecated.- Specified by:
StopEvent
in interfaceFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
-
$minus$greater
public FSM.$minus$greater$ $minus$greater()
Deprecated.Description copied from interface:FSM
This extractor is just convenience for matching a (S, S) pair, including a reminder what the new state is.- Specified by:
$minus$greater
in interfaceFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
- Returns:
- (undocumented)
-
StateTimeout
public FSM.StateTimeout$ StateTimeout()
Deprecated.Description copied from interface:FSM
This case object is received in case of a state timeout.- Specified by:
StateTimeout
in interfaceFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
- Returns:
- (undocumented)
-
akka$actor$FSM$_setter_$Event_$eq
protected void akka$actor$FSM$_setter_$Event_$eq(FSM.Event$ x$1)
Deprecated.- Specified by:
akka$actor$FSM$_setter_$Event_$eq
in interfaceFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
-
akka$actor$FSM$_setter_$StopEvent_$eq
protected void akka$actor$FSM$_setter_$StopEvent_$eq(FSM.StopEvent$ x$1)
Deprecated.- Specified by:
akka$actor$FSM$_setter_$StopEvent_$eq
in interfaceFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
-
akka$actor$FSM$_setter_$StateTimeout_$eq
protected void akka$actor$FSM$_setter_$StateTimeout_$eq(FSM.StateTimeout$ x$1)
Deprecated.Description copied from interface:FSM
This case object is received in case of a state timeout.- Specified by:
akka$actor$FSM$_setter_$StateTimeout_$eq
in interfaceFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
- Parameters:
x$1
- (undocumented)
-
listeners
protected java.util.Set<ActorRef> listeners()
Deprecated.
-
akka$routing$Listeners$_setter_$listeners_$eq
protected void akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
Deprecated.- Specified by:
akka$routing$Listeners$_setter_$listeners_$eq
in interfaceListeners
-
context
public ActorContext context()
Deprecated.Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API.getContext
returns aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
self
public final ActorRef self()
Deprecated.Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
-
akka$actor$Actor$_setter_$context_$eq
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Deprecated.- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
akka$actor$Actor$_setter_$self_$eq
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Deprecated.Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
akka$actor$Actor$_setter_$self_$eq
in interfaceActor
- Parameters:
x$1
- (undocumented)
-
tunnel
public ActorRef tunnel()
Deprecated.
-
tunnel_$eq
public void tunnel_$eq(ActorRef x$1)
Deprecated.
-
currentSerial
public int currentSerial()
Deprecated.
-
currentSerial_$eq
public void currentSerial_$eq(int x$1)
Deprecated.
-
lastAckSerial
public int lastAckSerial()
Deprecated.
-
lastAckSerial_$eq
public void lastAckSerial_$eq(int x$1)
Deprecated.
-
currentTarget
public ActorRef currentTarget()
Deprecated.
-
currentTarget_$eq
public void currentTarget_$eq(ActorRef x$1)
Deprecated.
-
attemptedReconnects
public int attemptedReconnects()
Deprecated.
-
attemptedReconnects_$eq
public void attemptedReconnects_$eq(int x$1)
Deprecated.
-
resendTimer
public java.lang.String resendTimer()
Deprecated.
-
reconnectTimer
public java.lang.String reconnectTimer()
Deprecated.
-
retryGateClosedFor
public long retryGateClosedFor()
Deprecated.
-
defaultConnectInterval
public scala.concurrent.duration.FiniteDuration defaultConnectInterval()
Deprecated.
-
initialState
public ReliableProxy.Connecting$ initialState()
Deprecated.
-
createTunnel
public void createTunnel(ActorRef target)
Deprecated.
-
supervisorStrategy
public OneForOneStrategy supervisorStrategy()
Deprecated.Description copied from interface:Actor
User overridable definition the strategy to use for supervising child actors.- Specified by:
supervisorStrategy
in interfaceActor
- Returns:
- (undocumented)
-
postStop
public void postStop()
Deprecated.Description copied from interface:Actor
User overridable callback. Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.- Specified by:
postStop
in interfaceActor
- Specified by:
postStop
in interfaceFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
-
scheduleTick
public void scheduleTick()
Deprecated.
-
nextSerial
public int nextSerial()
Deprecated.
-
send
public ReliableProxy.Message send(java.lang.Object msg, ActorRef snd)
Deprecated.
-
updateSerial
public scala.collection.immutable.Vector<ReliableProxy.Message> updateSerial(scala.collection.immutable.Vector<ReliableProxy.Message> q)
Deprecated.
-
resend
public scala.collection.immutable.Vector<ReliableProxy.Message> resend(scala.collection.immutable.Vector<ReliableProxy.Message> q)
Deprecated.
-
logResend
public void logResend(int size)
Deprecated.
-
terminated
public FSM.State<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>> terminated()
Deprecated.
-
scheduleReconnectTick
public void scheduleReconnectTick()
Deprecated.
-
resetBackoff
public void resetBackoff()
Deprecated.Reset backoff interval.This and nextBackoff are meant to be implemented by subclasses.
-
nextBackoff
public scala.concurrent.duration.FiniteDuration nextBackoff()
Deprecated.Returns the next retry interval duration. By default each interval is the same, reconnectAfter.- Returns:
- (undocumented)
-
-