akka.contrib.pattern
Class ReliableProxy$

java.lang.Object
  extended by akka.contrib.pattern.ReliableProxy$

public class ReliableProxy$
extends java.lang.Object


Field Summary
static ReliableProxy$ MODULE$
          Static reference to the singleton instance of this Scala object.
 
Constructor Summary
ReliableProxy$()
           
 
Method Summary
 ReliableProxy.Active$ active()
           
 int compare(int a, int b)
          Wrap-around aware comparison of integers: differences limited to 2**31-1 in magnitude will work correctly.
 ReliableProxy.Idle$ idle()
           
 Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter)
          Props with no reconnections.
 Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.concurrent.duration.FiniteDuration reconnectAfter)
          Props with no limit on reconnections.
 Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.concurrent.duration.FiniteDuration reconnectAfter, int maxReconnects)
          Java API Props.
 Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.Option<scala.concurrent.duration.FiniteDuration> reconnectAfter, scala.Option<java.lang.Object> maxReconnects)
          Scala API Props.
 Props receiver(ActorRef target, int currentSerial)
           
 ReliableProxy.Connecting$ reconnecting()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

MODULE$

public static final ReliableProxy$ MODULE$
Static reference to the singleton instance of this Scala object.

Constructor Detail

ReliableProxy$

public ReliableProxy$()
Method Detail

props

public Props props(ActorPath targetPath,
                   scala.concurrent.duration.FiniteDuration retryAfter,
                   scala.Option<scala.concurrent.duration.FiniteDuration> reconnectAfter,
                   scala.Option<java.lang.Object> maxReconnects)
Scala API Props. Arguments are detailed in the ReliableProxy constructor.

Parameters:
targetPath - (undocumented)
retryAfter - (undocumented)
reconnectAfter - (undocumented)
maxReconnects - (undocumented)
Returns:
(undocumented)

props

public Props props(ActorPath targetPath,
                   scala.concurrent.duration.FiniteDuration retryAfter,
                   scala.concurrent.duration.FiniteDuration reconnectAfter,
                   int maxReconnects)
Java API Props. Arguments are detailed in the ReliableProxy constructor.

Parameters:
targetPath - (undocumented)
retryAfter - (undocumented)
reconnectAfter - (undocumented)
maxReconnects - (undocumented)
Returns:
(undocumented)

props

public Props props(ActorPath targetPath,
                   scala.concurrent.duration.FiniteDuration retryAfter,
                   scala.concurrent.duration.FiniteDuration reconnectAfter)
Props with no limit on reconnections. Arguments are detailed in the ReliableProxy constructor.

Parameters:
targetPath - (undocumented)
retryAfter - (undocumented)
reconnectAfter - (undocumented)
Returns:
(undocumented)

props

public Props props(ActorPath targetPath,
                   scala.concurrent.duration.FiniteDuration retryAfter)
Props with no reconnections. Arguments are detailed in the ReliableProxy constructor.

Parameters:
targetPath - (undocumented)
retryAfter - (undocumented)
Returns:
(undocumented)

compare

public int compare(int a,
                   int b)
Wrap-around aware comparison of integers: differences limited to 2**31-1 in magnitude will work correctly.

Parameters:
a - (undocumented)
b - (undocumented)
Returns:
(undocumented)

receiver

public Props receiver(ActorRef target,
                      int currentSerial)

idle

public ReliableProxy.Idle$ idle()

active

public ReliableProxy.Active$ active()

reconnecting

public ReliableProxy.Connecting$ reconnecting()