Class StreamingDataSourceBuilder
- java.lang.Object
-
- com.launchdarkly.sdk.server.integrations.StreamingDataSourceBuilder
-
- All Implemented Interfaces:
ComponentConfigurer<DataSource>
public abstract class StreamingDataSourceBuilder extends java.lang.Object implements ComponentConfigurer<DataSource>
Contains methods for configuring the streaming data source.By default, the SDK uses a streaming connection to receive feature flag data from LaunchDarkly. If you want to customize the behavior of the connection, create a builder with
Components.streamingDataSource()
, change its properties with the methods of this class, and pass it toLDConfig.Builder.dataSource(ComponentConfigurer)
:LDConfig config = new LDConfig.Builder() .dataSource(Components.streamingDataSource().initialReconnectDelayMillis(500)) .build();
Note that this class is abstract; the actual implementation is created by calling
Components.streamingDataSource()
.- Since:
- 4.12.0
-
-
Field Summary
Fields Modifier and Type Field Description static java.time.Duration
DEFAULT_INITIAL_RECONNECT_DELAY
The default value forinitialReconnectDelay(Duration)
: 1000 milliseconds.protected java.time.Duration
initialReconnectDelay
protected java.lang.String
payloadFilter
-
Constructor Summary
Constructors Constructor Description StreamingDataSourceBuilder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StreamingDataSourceBuilder
initialReconnectDelay(java.time.Duration initialReconnectDelay)
Sets the initial reconnect delay for the streaming connection.StreamingDataSourceBuilder
payloadFilter(java.lang.String payloadFilter)
Sets the Payload Filter that will be used to filter the objects (flags, segments, etc.) from this data source.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.launchdarkly.sdk.server.subsystems.ComponentConfigurer
build
-
-
-
-
Field Detail
-
DEFAULT_INITIAL_RECONNECT_DELAY
public static final java.time.Duration DEFAULT_INITIAL_RECONNECT_DELAY
The default value forinitialReconnectDelay(Duration)
: 1000 milliseconds.
-
initialReconnectDelay
protected java.time.Duration initialReconnectDelay
-
payloadFilter
protected java.lang.String payloadFilter
-
-
Method Detail
-
initialReconnectDelay
public StreamingDataSourceBuilder initialReconnectDelay(java.time.Duration initialReconnectDelay)
Sets the initial reconnect delay for the streaming connection.The streaming service uses a backoff algorithm (with jitter) every time the connection needs to be reestablished. The delay for the first reconnection will start near this value, and then increase exponentially for any subsequent connection failures.
The default value is
DEFAULT_INITIAL_RECONNECT_DELAY
.- Parameters:
initialReconnectDelay
- the reconnect time base value; null to use the default- Returns:
- the builder
-
payloadFilter
public StreamingDataSourceBuilder payloadFilter(java.lang.String payloadFilter)
Sets the Payload Filter that will be used to filter the objects (flags, segments, etc.) from this data source.- Parameters:
payloadFilter
- the filter to be used- Returns:
- the builder
-
-