Package | Description |
---|---|
reactor.io.net |
Reactive network components are located in this package scope implementing the following exposed contract:
A
ReactorPeer NetServer/NetClient is a Publisher of
ReactorChannel that are themselves Publisher of input data. |
Modifier and Type | Method and Description |
---|---|
Spec.IncrementalBackoffReconnect |
Spec.IncrementalBackoffReconnect.address(InetSocketAddress address)
Add an address to the pool of addresses.
|
Spec.IncrementalBackoffReconnect |
Spec.IncrementalBackoffReconnect.address(String host,
int port)
Add an address to the pool of addresses.
|
static Spec.IncrementalBackoffReconnect |
NetStreams.backoffReconnect() |
Spec.IncrementalBackoffReconnect |
Spec.IncrementalBackoffReconnect.interval(long interval)
Set the reconnection interval.
|
Spec.IncrementalBackoffReconnect |
Spec.IncrementalBackoffReconnect.maxAttempts(long maxAttempts)
Sets the number of time that Reactor will attempt to connect or reconnect
before giving up.
|
Spec.IncrementalBackoffReconnect |
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 |
Spec.IncrementalBackoffReconnect.multiplier(long multiplier)
Set the backoff multiplier.
|
Copyright © 2016. All rights reserved.