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,
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(BiConsumer<Connection,ConnectionEvent> connectedHandler) |
Configures a handler that will be notified when a Connection has established. |
protected ConnectionOptions |
ConnectionOptions.copyInto(ConnectionOptions other) |
|
ConnectionOptions |
ConnectionOptions.defaultNextReceiverPolicy(NextReceiverPolicy policy) |
Configures the default next receiver policy for this connection and any session
that is created without specifying user defined session default options.
|
ConnectionOptions |
ConnectionOptions.desiredCapabilities(String... desiredCapabilities) |
|
ConnectionOptions |
ConnectionOptions.disconnectedHandler(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,
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,
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(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(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,
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(String password) |
Sets the password used when performing connection authentication.
|
ConnectionOptions |
ConnectionOptions.properties(Map<String,Object> properties) |
|
ConnectionOptions |
ConnectionOptions.reconnectedHandler(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 (default is disabled).
|
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,
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,
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(String user) |
Sets the user name used when performing connection authentication.
|
ConnectionOptions |
ConnectionOptions.virtualHost(String virtualHost) |
The virtual host value to provide to the remote when creating a new Connection. |