Uses of Class
org.apache.qpid.protonj2.client.StreamReceiverOptions
-
Uses of StreamReceiverOptions in org.apache.qpid.protonj2.client
Modifier and TypeMethodDescriptionStreamReceiverOptions.autoAccept
(boolean autoAccept) Controls if the created Receiver will automatically accept the deliveries that have been received by the application (default istrue
).StreamReceiverOptions.clone()
protected StreamReceiverOptions
StreamReceiverOptions.copyInto
(StreamReceiverOptions other) Copy all options from thisStreamReceiverOptions
instance into the instance provided.StreamReceiverOptions.creditWindow
(int creditWindow) A credit window value that will be used to maintain an window of credit for Receiver instances that are created.StreamReceiverOptions.drainTimeout
(long drainTimeout) Sets the drain timeout (in milliseconds) after which aReceiver
request to drain link credit is considered failed and the request will be marked as such.StreamReceiverOptions.drainTimeout
(long timeout, TimeUnit units) Sets the drain timeout value after which aReceiver
request to drain link credit is considered failed and the request will be marked as such.StreamReceiverOptions.readBufferSize
(int readBufferSize) Sets the incoming buffer capacity (in bytes) that theStreamReceiver
.protected StreamReceiverOptions
StreamReceiverOptions.self()
Modifier and TypeMethodDescriptionprotected StreamReceiverOptions
StreamReceiverOptions.copyInto
(StreamReceiverOptions other) Copy all options from thisStreamReceiverOptions
instance into the instance provided.Connection.openStreamReceiver
(String address, StreamReceiverOptions receiverOptions) Creates a streaming message receiver used to consume large messages from the given node address.ModifierConstructorDescriptionCreate aStreamReceiverOptions
instance that copies all configuration from the givenStreamReceiverOptions
instance. -
Uses of StreamReceiverOptions in org.apache.qpid.protonj2.client.impl
Modifier and TypeMethodDescriptionClientConnection.openStreamReceiver
(String address, StreamReceiverOptions receiverOptions)