Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_INTERVAL |
static long |
DEFAULT_MAX_ATTEMPTS |
static long |
DEFAULT_MULTIPLIER |
Modifier and Type | Method and Description |
---|---|
Spec.IncrementalBackoffReconnect |
address(InetSocketAddress address)
Add an address to the pool of addresses.
|
Spec.IncrementalBackoffReconnect |
address(String host,
int port)
Add an address to the pool of addresses.
|
long |
determineInterval(int attempt)
Determine the period in milliseconds between reconnection attempts.
|
Reconnect |
get()
Get an object.
|
Spec.IncrementalBackoffReconnect |
interval(long interval)
Set the reconnection interval.
|
Spec.IncrementalBackoffReconnect |
maxAttempts(long maxAttempts)
Sets the number of time that Reactor will attempt to connect or reconnect
before giving up.
|
Spec.IncrementalBackoffReconnect |
maxInterval(long maxInterval)
Set the maximum reconnection interval that will be applied if the multiplier
is set to a value greather than one.
|
Spec.IncrementalBackoffReconnect |
multiplier(long multiplier)
Set the backoff multiplier.
|
public static final long DEFAULT_INTERVAL
public static final long DEFAULT_MULTIPLIER
public static final long DEFAULT_MAX_ATTEMPTS
public Spec.IncrementalBackoffReconnect interval(long interval)
interval
- the period reactor waits between attemps to reconnect disconnected peerspublic Spec.IncrementalBackoffReconnect maxInterval(long maxInterval)
maxInterval
- public Spec.IncrementalBackoffReconnect multiplier(long multiplier)
multiplier
- public Spec.IncrementalBackoffReconnect maxAttempts(long maxAttempts)
maxAttempts
- The max number of attempts made before failing.public Spec.IncrementalBackoffReconnect address(InetSocketAddress address)
address
- public Spec.IncrementalBackoffReconnect address(String host, int port)
host
- port
- public long determineInterval(int attempt)
attempt
- the number of times a reconnection has been attemptedCopyright © 2017. All rights reserved.