akka.contrib.pattern

Class ReliableProxy$

java.lang.Object

akka.contrib.pattern.ReliableProxy$

public class ReliableProxy$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static ReliableProxy$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
ReliableProxy$()

Method Summary

Modifier and Type	Method and Description
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()