Package org.apache.qpid.protonj2.client

Class StreamReceiverOptions

  • All Implemented Interfaces:
    java.lang.Cloneable
    public final class StreamReceiverOptions
extends LinkOptions<StreamReceiverOptions>
implements java.lang.Cloneable
    Options class that controls various aspects of a StreamReceiver instance and how a streamed message transfer is written.

    • Field Detail

      • DEFAULT_READ_BUFFER_SIZE

        public static final int DEFAULT_READ_BUFFER_SIZE
        Defines the default read buffering size which is used to control how much incoming data can be buffered before the remote has back pressured applied to avoid out of memory conditions.
        See Also:
        Constant Field Values

    • Constructor Detail

      • StreamReceiverOptions

        public StreamReceiverOptions()
        Creates a StreamReceiverOptions instance with default values for all options

    • Method Detail

      • readBufferSize

        public int readBufferSize()
        Returns:
        the configured session capacity for the parent session of the StreamReceiver.

      • readBufferSize

        public StreamReceiverOptions readBufferSize​(int readBufferSize)
        Sets the incoming buffer capacity (in bytes) that the StreamReceiver.

        When the remote peer is sending incoming data for a StreamReceiverMessage the amount that is stored in memory before back pressure is applied to the remote is controlled by this option. If the user does not read incoming data as it arrives this limit can prevent out of memory errors that might otherwise arise as the remote attempts to immediately send all contents of very large message payloads.

        Parameters:
        readBufferSize - The number of bytes that the StreamReceiver will buffer for a given StreamReceiverMessage.
        Returns:
        this StreamReceiverOptions instance.

      • autoAccept

        public StreamReceiverOptions autoAccept​(boolean autoAccept)
        Controls if the created Receiver will automatically accept the deliveries that have been received by the application (default is true).
        Parameters:
        autoAccept - The value to assign for auto delivery acceptance.
        Returns:
        this StreamReceiverOptions instance.

      • autoAccept

        public boolean autoAccept()
        Returns:
        the current value of the Receiver auto accept setting.

      • creditWindow

        public int creditWindow()
        Returns:
        the credit window configuration that will be applied to created Receiver instances.

      • creditWindow

        public StreamReceiverOptions creditWindow​(int creditWindow)
        A credit window value that will be used to maintain an window of credit for Receiver instances that are created. The Receiver will allow up to the credit window amount of incoming deliveries to be queued and as they are read from the Receiver the window will be extended to maintain a consistent backlog of deliveries. The default is to configure a credit window of 10.

        To disable credit windowing and allow the client application to control the credit on the Receiver link the credit window value should be set to zero.

        Parameters:
        creditWindow - The assigned credit window value to use.
        Returns:
        this StreamReceiverOptions instance.

      • drainTimeout

        public long drainTimeout()
        Returns:
        the configured drain timeout value that will use to fail a pending drain request.

      • drainTimeout

        public StreamReceiverOptions drainTimeout​(long drainTimeout)
        Sets the drain timeout (in milliseconds) after which a Receiver request to drain link credit is considered failed and the request will be marked as such.
        Parameters:
        drainTimeout - the drainTimeout to use for receiver links.
        Returns:
        this StreamReceiverOptions instance.

      • drainTimeout

        public StreamReceiverOptions drainTimeout​(long timeout,
                                          java.util.concurrent.TimeUnit units)
        Sets the drain timeout value after which a Receiver request to drain link credit is considered failed and the request will be marked as such.
        Parameters:
        timeout - Timeout value to wait for a remote response.
        units - The TimeUnit that defines the timeout span.
        Returns:
        this StreamReceiverOptions instance.