Class StreamingDataSourceBuilder

    • Field Detail

      • DEFAULT_INITIAL_RECONNECT_DELAY

        public static final java.time.Duration DEFAULT_INITIAL_RECONNECT_DELAY
        The default value for initialReconnectDelay(Duration): 1000 milliseconds.
      • initialReconnectDelay

        protected java.time.Duration initialReconnectDelay
      • payloadFilter

        protected java.lang.String payloadFilter
    • Constructor Detail

      • StreamingDataSourceBuilder

        public StreamingDataSourceBuilder()
    • 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