Uses of Class
org.apache.qpid.protonj2.client.StreamSenderOptions
-
Uses of StreamSenderOptions in org.apache.qpid.protonj2.client
Modifier and TypeMethodDescriptionStreamSenderOptions.clone()
protected StreamSenderOptions
StreamSenderOptions.copyInto
(StreamSenderOptions other) Copy all options from thisStreamSenderOptions
instance into the instance provided.StreamSenderOptions.deliveryTagGeneratorSupplier
(Supplier<DeliveryTagGenerator> supplier) Configures aSupplier
which provides unique instances ofDeliveryTagGenerator
objects for anyStreamSender
created using these options.StreamSenderOptions.pendingWritesBufferSize
(int pendingWritesBufferSize) Sets the overall number of bytes the stream sender will allow to be pending for write before applying back pressure to the stream write caller.protected StreamSenderOptions
StreamSenderOptions.self()
StreamSenderOptions.sendTimeout
(long sendTimeout) Configures the timeout used when awaiting a send operation to complete.StreamSenderOptions.sendTimeout
(long timeout, TimeUnit units) Configures the timeout used when awaiting a send operation to complete.StreamSenderOptions.writeBufferSize
(int writeBufferSize) Sets the overall number of bytes the stream sender will buffer before automatically flushing the currently buffered bytes.Modifier and TypeMethodDescriptionprotected StreamSenderOptions
StreamSenderOptions.copyInto
(StreamSenderOptions other) Copy all options from thisStreamSenderOptions
instance into the instance provided.Connection.openStreamSender
(String address, StreamSenderOptions senderOptions) Creates a streaming sender used to send large messages to the given node address.ModifierConstructorDescriptionStreamSenderOptions
(StreamSenderOptions options) Create aStreamSenderOptions
instance that copies all configuration from the givenStreamSenderOptions
instance. -
Uses of StreamSenderOptions in org.apache.qpid.protonj2.client.impl
Modifier and TypeMethodDescriptionClientConnection.openStreamSender
(String address, StreamSenderOptions senderOptions)