Uses of Class
org.apache.qpid.protonj2.client.ConnectionOptions
-
Uses of ConnectionOptions in org.apache.qpid.protonj2.client
Modifier and TypeMethodDescriptionConnectionOptions.channelMax
(int channelMax) Configure the channel maximum value for the newConnection
created with these options.ConnectionOptions.clone()
ConnectionOptions.closeTimeout
(long closeTimeout) Configures the timeout used when awaiting a response from the remote that a request to close a resource such as aConnection
,Session
,Sender
orReceiver
h as been honored.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 aConnection
,Session
,Sender
orReceiver
h as been honored.ConnectionOptions.connectedHandler
(BiConsumer<Connection, ConnectionEvent> connectedHandler) Configures a handler that will be notified when aConnection
has established.protected ConnectionOptions
ConnectionOptions.copyInto
(ConnectionOptions other) Copy all options from thisConnectionOptions
instance into the instance provided.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.desiredCapabilities
(String... desiredCapabilities) Sets the collection of capabilities to request from the remote for a newConnection
created using theseConnectionOptions
.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.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.ConnectionOptions.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.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.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.interruptedHandler
(BiConsumer<Connection, DisconnectionEvent> interruptedHandler) Configures a handler that will be notified when the currentConnection
experiences an interruption.ConnectionOptions.maxFrameSize
(int maxFrameSize) Sets the max frame size (in bytes), values of -1 indicates to use the client selected default.ConnectionOptions.offeredCapabilities
(String... offeredCapabilities) Sets the collection of capabilities to offer to the remote from a newConnection
created using theseConnectionOptions
.ConnectionOptions.openTimeout
(long openTimeout) Configures the timeout used when awaiting a response from the remote that a request to open a resource such as aConnection
,Session
,Sender
orReceiver
has been honored.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 aConnection
,Session
,Sender
orReceiver
has been honored.Sets the password used when performing connection authentication.ConnectionOptions.properties
(Map<String, Object> properties) Sets aMap
of properties to convey to the remote when a newConnection
is created from theseConnectionOptions
.ConnectionOptions.reconnectedHandler
(BiConsumer<Connection, ConnectionEvent> reconnectedHandler) Configures a handler that will be notified when aConnection
that has previously experienced and interruption has been reconnected to a remote based on the reconnection configuration.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.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.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.sendTimeout
(long sendTimeout) Configures the timeout used when awaiting a send operation to complete.ConnectionOptions.sendTimeout
(long timeout, TimeUnit units) Configures the timeout used when awaiting a send operation to complete.ConnectionOptions.sslEnabled
(boolean sslEnabled) Controls if the connection will attempt to connect using a secure IO layer or not.ConnectionOptions.traceFrames
(boolean traceFrames) Configure if the newly created connection should enabled AMQP frame tracing to the system output.Sets the user name used when performing connection authentication.ConnectionOptions.virtualHost
(String virtualHost) The virtual host value to provide to the remote when creating a newConnection
.Modifier and TypeMethodDescriptionClient.connect
(String host, int port, ConnectionOptions options) Connect to the specified host and port, with given connection options.Client.connect
(String host, ConnectionOptions options) Connect to the specified host, using the default port, without credentials and with all connection options set to their defaults.protected ConnectionOptions
ConnectionOptions.copyInto
(ConnectionOptions other) Copy all options from thisConnectionOptions
instance into the instance provided.ModifierConstructorDescriptionConnectionOptions
(ConnectionOptions options) Creates aConnectionOptions
instance that is a copy of the given instance. -
Uses of ConnectionOptions in org.apache.qpid.protonj2.client.impl
Modifier and TypeMethodDescriptionClientInstance.connect
(String host, int port, ConnectionOptions options) ClientInstance.connect
(String host, ConnectionOptions options)