Package markets.alpaca.client.ws

Class AlpacaStreamReconnectPolicy

java.lang.Object

markets.alpaca.client.ws.AlpacaStreamReconnectPolicy

public final class AlpacaStreamReconnectPolicy
extends Object

Reconnect policy for Alpaca WebSocket stream clients.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	AlpacaStreamReconnectPolicy.Builder	Builder for AlpacaStreamReconnectPolicy.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	UNLIMITED_ATTEMPTS	Use this value for AlpacaStreamReconnectPolicy.Builder.maxAttempts(int) to retry forever.

Method Summary

Modifier and Type	Method	Description
boolean	allowsAttempt(int attempt)
static AlpacaStreamReconnectPolicy.Builder	builder()
static AlpacaStreamReconnectPolicy	defaultPolicy()	Returns the default policy: 10 attempts, starting at 1 second, capped at 64 seconds, with 20% jitter.
long	delayMillisForAttempt(int attempt)
static AlpacaStreamReconnectPolicy	disabled()	Returns a policy that never reconnects after an unexpected close or transport failure.
Duration	initialBackoff()
long	jitteredDelayMillisForAttempt(int attempt)	Returns the reconnect delay for attempt, with configured jitter applied.
double	jitterRatio()	Ratio used to randomize reconnect delays.
int	maxAttempts()	Maximum reconnect attempts after one successful connection.
Duration	maxBackoff()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

UNLIMITED_ATTEMPTS

public static final int UNLIMITED_ATTEMPTS

Use this value for AlpacaStreamReconnectPolicy.Builder.maxAttempts(int) to retry forever.

See Also:

• Constant Field Values

Method Details

defaultPolicy

public static AlpacaStreamReconnectPolicy defaultPolicy()

Returns the default policy: 10 attempts, starting at 1 second, capped at 64 seconds, with 20% jitter.

disabled

public static AlpacaStreamReconnectPolicy disabled()

Returns a policy that never reconnects after an unexpected close or transport failure.

builder

public static AlpacaStreamReconnectPolicy.Builder builder()

initialBackoff

public Duration initialBackoff()

maxBackoff

public Duration maxBackoff()

maxAttempts

public int maxAttempts()

Maximum reconnect attempts after one successful connection.

0 disables reconnects. UNLIMITED_ATTEMPTS retries forever.

jitterRatio

public double jitterRatio()

Ratio used to randomize reconnect delays. 0 disables jitter.

allowsAttempt

public boolean allowsAttempt(int attempt)

delayMillisForAttempt

public long delayMillisForAttempt(int attempt)

jitteredDelayMillisForAttempt

public long jitteredDelayMillisForAttempt(int attempt)

Returns the reconnect delay for attempt, with configured jitter applied.