Connection |
Engine.connection() |
|
Connection |
Link.getConnection() |
|
Connection |
Session.getConnection() |
|
Connection |
Connection.getParent() |
|
Connection |
Session.getParent() |
|
Connection |
Connection.negotiate() |
If not already negotiated this method initiates the AMQP protocol negotiation phase of
the connection process sending the AMQPHeader to the remote peer. |
Connection |
Connection.negotiate(EventHandler<AMQPHeader> remoteAMQPHeaderHandler) |
If not already negotiated this method initiates the AMQP protocol negotiation phase of
the connection process sending the AMQPHeader to the remote peer. |
Connection |
Connection.receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler) |
Sets a EventHandler for when an AMQP Attach frame is received from the remote peer for a receiving link. |
Connection |
Connection.senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler) |
Sets a EventHandler for when an AMQP Attach frame is received from the remote peer for a sending link. |
Connection |
Connection.sessionOpenHandler(EventHandler<Session> remoteSessionOpenEventHandler) |
Sets a EventHandler for when an AMQP Begin frame is received from the remote peer. |
Connection |
Connection.setChannelMax(int channelMax) |
Set the channel max value for this Connection.
|
Connection |
Connection.setContainerId(String containerId) |
Sets the Container Id to be used when opening this Connection.
|
Connection |
Connection.setHostname(String hostname) |
Set the name of the host (either fully qualified or relative) to which this
connection is connecting to.
|
Connection |
Connection.setIdleTimeout(long idleTimeout) |
Set the idle timeout value for this Connection.
|
Connection |
Connection.setMaxFrameSize(long maxFrameSize) |
Sets the maximum frame size allowed for this connection, which is the largest single frame
that the remote can send to this Connection before it will close the connection with
an error condition indicating the violation. |
Connection |
Engine.start() |
Starts the engine and returns the Connection instance that is bound to this Engine. |
Connection |
Connection.tickAuto(ScheduledExecutorService executor) |
|
Connection |
Connection.transactionManagerOpenHandler(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) |
Sets a EventHandler for when an AMQP Attach frame is received from the remote peer for a transaction
coordination link. |