akka.contrib.pattern
Class ReliableProxy$

java.lang.Object
  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()