public class ReliableProxy$
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static ReliableProxy$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
ReliableProxy$() |
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() |
public static final ReliableProxy$ MODULE$
public Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.Option<scala.concurrent.duration.FiniteDuration> reconnectAfter, scala.Option<java.lang.Object> maxReconnects)
ReliableProxy
constructor.targetPath
- (undocumented)retryAfter
- (undocumented)reconnectAfter
- (undocumented)maxReconnects
- (undocumented)public Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.concurrent.duration.FiniteDuration reconnectAfter, int maxReconnects)
ReliableProxy
constructor.targetPath
- (undocumented)retryAfter
- (undocumented)reconnectAfter
- (undocumented)maxReconnects
- (undocumented)public Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter, scala.concurrent.duration.FiniteDuration reconnectAfter)
ReliableProxy
constructor.targetPath
- (undocumented)retryAfter
- (undocumented)reconnectAfter
- (undocumented)public Props props(ActorPath targetPath, scala.concurrent.duration.FiniteDuration retryAfter)
ReliableProxy
constructor.targetPath
- (undocumented)retryAfter
- (undocumented)public int compare(int a, int b)
a
- (undocumented)b
- (undocumented)public ReliableProxy.Idle$ idle()
public ReliableProxy.Active$ active()
public ReliableProxy.Connecting$ reconnecting()