ConnectionOptions |
ConnectionOptions.channelMax(int channelMax) |
Configure the channel maximum value for the new Connection created with these options. |
ConnectionOptions |
ConnectionOptions.clone() |
|
ConnectionOptions |
ConnectionOptions.closeTimeout(long closeTimeout) |
Configures the timeout used when awaiting a response from the remote that a request to close
a resource such as a Connection, Session, Sender or Receiver h
as been honored. |
ConnectionOptions |
ConnectionOptions.closeTimeout(long timeout,
java.util.concurrent.TimeUnit units) |
Configures the timeout used when awaiting a response from the remote that a request to close
a resource such as a Connection, Session, Sender or Receiver h
as been honored. |
ConnectionOptions |
ConnectionOptions.connectedHandler(java.util.function.BiConsumer<Connection,ConnectionEvent> connectedHandler) |
Configures a handler that will be notified when a Connection has established. |
protected ConnectionOptions |
ConnectionOptions.copyInto(ConnectionOptions other) |
|
ConnectionOptions |
ConnectionOptions.desiredCapabilities(java.lang.String... desiredCapabilities) |
|
ConnectionOptions |
ConnectionOptions.disconnectedHandler(java.util.function.BiConsumer<Connection,DisconnectionEvent> disconnectedHandler) |
Configures a handler that will be notified when the connection has failed and cannot be recovered
should reconnect be enabled.
|
ConnectionOptions |
ConnectionOptions.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. |
ConnectionOptions |
ConnectionOptions.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. |
ConnectionOptions |
ConnectionOptions.idleTimeout(long idleTimeout) |
Sets the idle timeout (in milliseconds) after which the connection will
be closed if the peer has not send any data.
|
ConnectionOptions |
ConnectionOptions.idleTimeout(long timeout,
java.util.concurrent.TimeUnit units) |
Sets the idle timeout value after which the connection will be closed
if the peer has not send any data.
|
ConnectionOptions |
ConnectionOptions.interruptedHandler(java.util.function.BiConsumer<Connection,DisconnectionEvent> interruptedHandler) |
Configures a handler that will be notified when the current Connection experiences an
interruption. |
ConnectionOptions |
ConnectionOptions.maxFrameSize(int maxFrameSize) |
Sets the max frame size (in bytes), values of -1 indicates to use the client selected default.
|
ConnectionOptions |
ConnectionOptions.offeredCapabilities(java.lang.String... offeredCapabilities) |
|
ConnectionOptions |
ConnectionOptions.openTimeout(long openTimeout) |
Configures the timeout used when awaiting a response from the remote that a request to open
a resource such as a Connection, Session, Sender or Receiver
has been honored. |
ConnectionOptions |
ConnectionOptions.openTimeout(long timeout,
java.util.concurrent.TimeUnit units) |
Configures the timeout used when awaiting a response from the remote that a request to open
a resource such as a Connection, Session, Sender or Receiver
has been honored. |
ConnectionOptions |
ConnectionOptions.password(java.lang.String password) |
Sets the password used when performing connection authentication.
|
ConnectionOptions |
ConnectionOptions.properties(java.util.Map<java.lang.String,java.lang.Object> properties) |
|
ConnectionOptions |
ConnectionOptions.reconnectedHandler(java.util.function.BiConsumer<Connection,ConnectionEvent> reconnectedHandler) |
Configures a handler that will be notified when a Connection that has previously
experienced and interruption has been reconnected to a remote based on the reconnection
configuration. |
ConnectionOptions |
ConnectionOptions.reconnectEnabled(boolean reconnectEnabled) |
Controls if the connection will attempt to reconnect if unable to connect immediately
or if an existing connection fails.
|
ConnectionOptions |
ConnectionOptions.requestTimeout(long requestTimeout) |
Configures the timeout used when awaiting a response from the remote that a request to
perform some action such as starting a new transaction.
|
ConnectionOptions |
ConnectionOptions.requestTimeout(long timeout,
java.util.concurrent.TimeUnit units) |
Configures the timeout used when awaiting a response from the remote that a request to
perform some action such as starting a new transaction.
|
ConnectionOptions |
ConnectionOptions.sendTimeout(long sendTimeout) |
Configures the timeout used when awaiting a send operation to complete.
|
ConnectionOptions |
ConnectionOptions.sendTimeout(long timeout,
java.util.concurrent.TimeUnit units) |
Configures the timeout used when awaiting a send operation to complete.
|
ConnectionOptions |
ConnectionOptions.sslEnabled(boolean sslEnabled) |
Controls if the connection will attempt to connect using a secure IO layer or not.
|
ConnectionOptions |
ConnectionOptions.traceFrames(boolean traceFrames) |
Configure if the newly created connection should enabled AMQP frame tracing to the
system output.
|
ConnectionOptions |
ConnectionOptions.user(java.lang.String user) |
Sets the user name used when performing connection authentication.
|
ConnectionOptions |
ConnectionOptions.virtualHost(java.lang.String virtualHost) |
The virtual host value to provide to the remote when creating a new Connection. |