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 the ReliableProxy 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 the ReliableProxy 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 the ReliableProxy constructor.
    
    Parameters:
    
    targetPath - (undocumented)
    
    retryAfter - (undocumented)
    
    Returns:
    
    (undocumented)
  - compare
```
public static int compare(int a,
                          int b)
```
    Deprecated.
  - receiver
```
public static Props receiver(ActorRef target,
                             int currentSerial)
```
    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 interface ReliableProxyDebugLogging
  - 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 interface ReliableProxyDebugLogging
  - debugEvent
```
public boolean debugEvent()
```
    Deprecated.
    
    Specified by:
    
    debugEvent in interface FSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
    
    Specified by:
    
    debugEvent in interface LoggingFSM<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 interface LoggingFSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
  - Event
```
public FSM.Event$ Event()
```
    Deprecated.
    
    Specified by:
    
    Event in interface FSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
  - StopEvent
```
public FSM.StopEvent$ StopEvent()
```
    Deprecated.
    
    Specified by:
    
    StopEvent in interface FSM<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 interface FSM<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 interface FSM<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 interface FSM<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 interface FSM<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 interface FSM<ReliableProxy.State,scala.collection.immutable.Vector<ReliableProxy.Message>>
    
    Parameters:
    
    x$1 - (undocumented)
  - listeners
```
protected java.util.Set<ActorRef> listeners()
```
    Deprecated.
    
    Specified by:
    
    listeners in interface Listeners
  - 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 interface Listeners
  - 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 as forward.
    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 a AbstractActor.ActorContext, which is the Java API of the actor context.
    
    Specified by:
    
    context in interface Actor
    
    Returns:
    
    (undocumented)
  - 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
    Specified by:
    
    self in interface Actor
    
    Returns:
    
    (undocumented)
  - 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 interface Actor
  - 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 interface Actor
    
    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 interface Actor
    
    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 interface Actor
    
    Specified by:
    
    postStop in interface FSM<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)

Class ReliableProxy

Nested Class Summary

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

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

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface akka.actor.Actor

Methods inherited from interface akka.actor.ActorLogging

Methods inherited from interface akka.actor.FSM

Methods inherited from interface akka.routing.Listeners

Methods inherited from interface akka.actor.LoggingFSM

Methods inherited from interface akka.contrib.pattern.ReliableProxyDebugLogging

Constructor Detail

ReliableProxy

Method Detail

props

props

props

props

compare

receiver

idle

active

reconnecting

debug

akka$contrib$pattern$ReliableProxyDebugLogging$_setter_$debug_$eq

debugEvent

akka$actor$LoggingFSM$_setter_$debugEvent_$eq

Event

StopEvent

$minus$greater

StateTimeout

akka$actor$FSM$_setter_$Event_$eq

akka$actor$FSM$_setter_$StopEvent_$eq

akka$actor$FSM$_setter_$StateTimeout_$eq

listeners

akka$routing$Listeners$_setter_$listeners_$eq

context

self

akka$actor$Actor$_setter_$context_$eq

akka$actor$Actor$_setter_$self_$eq

tunnel

tunnel_$eq

currentSerial

currentSerial_$eq

lastAckSerial

lastAckSerial_$eq

currentTarget

currentTarget_$eq

attemptedReconnects

attemptedReconnects_$eq

resendTimer

reconnectTimer

retryGateClosedFor

defaultConnectInterval

initialState

createTunnel

supervisorStrategy

postStop

scheduleTick

nextSerial

send

updateSerial

resend

logResend

terminated

scheduleReconnectTick

resetBackoff

nextBackoff