Uses of Interface
org.apache.qpid.protonj2.engine.Connection
-
Uses of Connection in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescriptionEngine.connection()
Gets theConnection
instance that is associated with thisEngine
instance.Link.getConnection()
Session.getConnection()
Connection.getParent()
Session.getParent()
Connection.negotiate()
If not already negotiated this method initiates the AMQP protocol negotiation phase of the connection process sending theAMQPHeader
to the remote peer.Connection.negotiate
(EventHandler<AMQPHeader> remoteAMQPHeaderHandler) If not already negotiated this method initiates the AMQP protocol negotiation phase of the connection process sending theAMQPHeader
to the remote peer.Connection.receiverOpenHandler
(EventHandler<Receiver> remoteReceiverOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a receiving link.Connection.senderOpenHandler
(EventHandler<Sender> remoteSenderOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a sending link.Connection.sessionOpenHandler
(EventHandler<Session> remoteSessionOpenEventHandler) Sets aEventHandler
for when an AMQP Begin frame is received from the remote peer.Connection.setChannelMax
(int channelMax) Set the channel max value for this Connection.Connection.setContainerId
(String containerId) Sets the Container Id to be used when opening this Connection.Connection.setHostname
(String hostname) Set the name of the host (either fully qualified or relative) to which this connection is connecting to.Connection.setIdleTimeout
(long idleTimeout) Set the idle timeout value for this 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 thisConnection
before it will close the connection with an error condition indicating the violation.Engine.start()
Starts the engine and returns theConnection
instance that is bound to this Engine.Connection.tickAuto
(ScheduledExecutorService executor) Convenience method which is the same as callingEngine.tickAuto(ScheduledExecutorService)
.Convenience method which is the same as callingEngine.tickAuto(Scheduler)
.Connection.transactionManagerOpenHandler
(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a transaction coordination link. -
Uses of Connection in org.apache.qpid.protonj2.engine.impl
Modifier and TypeMethodDescriptionProtonConnection.getParent()
ProtonConnection.negotiate()
ProtonConnection.negotiate
(EventHandler<AMQPHeader> remoteAMQPHeaderHandler) ProtonConnection.setMaxFrameSize
(long maxFrameSize) ProtonConnection.tickAuto
(ScheduledExecutorService executor)