Uses of Interface
io.vertx.proton.ProtonConnection

Packages that use ProtonConnection

Package	Description
io.vertx.amqp.impl
io.vertx.proton
io.vertx.proton.impl
io.vertx.proton.sasl
io.vertx.proton.streams

Uses of ProtonConnection in io.vertx.amqp.impl

Methods in io.vertx.amqp.impl that return ProtonConnection

Modifier and Type	Method and Description
ProtonConnection	AmqpConnectionImpl.unwrap() Allows retrieving the underlying ProtonConnection.

Uses of ProtonConnection in io.vertx.proton

Methods in io.vertx.proton that return ProtonConnection

Modifier and Type	Method and Description
ProtonConnection	ProtonConnection.close() Closes the AMQP connection, i.e.
ProtonConnection	ProtonConnection.closeHandler(Handler<AsyncResult<ProtonConnection>> remoteCloseHandler) Sets a handler for when an AMQP Close frame is received from the remote peer.
ProtonConnection	ProtonConnection.disconnectHandler(Handler<ProtonConnection> disconnectHandler) Sets a handler for when the underlying transport connection indicates it has disconnected.
ProtonConnection	ProtonSession.getConnection() Gets the connection this session is on.
ProtonConnection	ProtonConnection.open() Opens the AMQP connection, i.e.
ProtonConnection	ProtonConnection.openHandler(Handler<AsyncResult<ProtonConnection>> remoteOpenHandler) Sets a handler for when an AMQP Open frame is received from the remote peer.
ProtonConnection	ProtonConnection.receiverOpenHandler(Handler<ProtonReceiver> remoteReceiverOpenHandler) Sets a handler for when an AMQP Attach frame is received from the remote peer for a receiving link.
ProtonConnection	ProtonConnection.senderOpenHandler(Handler<ProtonSender> remoteSenderOpenHandler) Sets a handler for when an AMQP Attach frame is received from the remote peer for a sending link.
ProtonConnection	ProtonConnection.sessionOpenHandler(Handler<ProtonSession> remoteSessionOpenHandler) Sets a handler for when an AMQP Begin frame is received from the remote peer.
ProtonConnection	ProtonConnection.setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) Sets the local ErrorCondition object.
ProtonConnection	ProtonConnection.setContainer(String container) Sets the container id value advertised to peers in the AMQP Open frame.
ProtonConnection	ProtonConnection.setDesiredCapabilities(org.apache.qpid.proton.amqp.Symbol[] capabilities) Sets the desired connection capabilities to be sent to the remote peer in our Open frame.
ProtonConnection	ProtonConnection.setHostname(String hostname) Sets the hostname value requested of/advertised to peers in the AMQP Open frame.
ProtonConnection	ProtonConnection.setOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[] capabilities) Sets the offered connection capabilities to be sent to the remote peer in our Open frame.
ProtonConnection	ProtonConnection.setProperties(Map<org.apache.qpid.proton.amqp.Symbol,Object> properties) Sets the connection properties map to be sent to the remote peer in our Open frame.

Methods in io.vertx.proton that return types with arguments of type ProtonConnection

Modifier and Type	Method and Description
Handler<ProtonConnection>	ProtonServer.connectHandler() Returns the current connectHandler.

Method parameters in io.vertx.proton with type arguments of type ProtonConnection

Modifier and Type	Method and Description
ProtonConnection	ProtonConnection.closeHandler(Handler<AsyncResult<ProtonConnection>> remoteCloseHandler) Sets a handler for when an AMQP Close frame is received from the remote peer.
void	ProtonClient.connect(ProtonClientOptions options, String host, int port, Handler<AsyncResult<ProtonConnection>> connectionHandler) Connect to the given host and port, without credentials.
void	ProtonClient.connect(ProtonClientOptions options, String host, int port, String username, String password, Handler<AsyncResult<ProtonConnection>> connectionHandler) Connect to the given host and port, with credentials (if required by server peer).
void	ProtonClient.connect(String host, int port, Handler<AsyncResult<ProtonConnection>> connectionHandler) Connect to the given host and port, without credentials.
void	ProtonClient.connect(String host, int port, String username, String password, Handler<AsyncResult<ProtonConnection>> connectionHandler) Connect to the given host and port, with credentials (if required by server peer).
ProtonServer	ProtonServer.connectHandler(Handler<ProtonConnection> handler) The handler called when a new client connection is accepted.
ProtonConnection	ProtonConnection.disconnectHandler(Handler<ProtonConnection> disconnectHandler) Sets a handler for when the underlying transport connection indicates it has disconnected.
ProtonConnection	ProtonConnection.openHandler(Handler<AsyncResult<ProtonConnection>> remoteOpenHandler) Sets a handler for when an AMQP Open frame is received from the remote peer.

Uses of ProtonConnection in io.vertx.proton.impl

Classes in io.vertx.proton.impl that implement ProtonConnection

Modifier and Type	Class and Description
class	ProtonConnectionImpl

Methods in io.vertx.proton.impl that return ProtonConnection

Modifier and Type	Method and Description
ProtonConnection	ProtonConnectionImpl.close()
ProtonConnection	ProtonConnectionImpl.closeHandler(Handler<AsyncResult<ProtonConnection>> closeHandler)
ProtonConnection	ProtonConnectionImpl.disconnectHandler(Handler<ProtonConnection> disconnectHandler)
ProtonConnection	ProtonSessionImpl.getConnection()
ProtonConnection	ProtonConnectionImpl.open()
ProtonConnection	ProtonConnectionImpl.openHandler(Handler<AsyncResult<ProtonConnection>> openHandler)
ProtonConnection	ProtonConnectionImpl.receiverOpenHandler(Handler<ProtonReceiver> remoteReceiverOpenHandler)
ProtonConnection	ProtonConnectionImpl.senderOpenHandler(Handler<ProtonSender> remoteSenderOpenHandler)
ProtonConnection	ProtonConnectionImpl.sessionOpenHandler(Handler<ProtonSession> remoteSessionOpenHandler)

Methods in io.vertx.proton.impl that return types with arguments of type ProtonConnection

Modifier and Type	Method and Description
Handler<ProtonConnection>	ProtonServerImpl.connectHandler()

Methods in io.vertx.proton.impl with parameters of type ProtonConnection

Modifier and Type	Method and Description
void	ProtonSaslServerAuthenticatorImpl.init(NetSocket socket, ProtonConnection protonConnection, org.apache.qpid.proton.engine.Transport transport)
void	ProtonSaslClientAuthenticatorImpl.init(NetSocket socket, ProtonConnection protonConnection, org.apache.qpid.proton.engine.Transport transport)

Method parameters in io.vertx.proton.impl with type arguments of type ProtonConnection

Modifier and Type	Method and Description
ProtonConnection	ProtonConnectionImpl.closeHandler(Handler<AsyncResult<ProtonConnection>> closeHandler)
void	ProtonClientImpl.connect(ProtonClientOptions options, String host, int port, Handler<AsyncResult<ProtonConnection>> handler)
void	ProtonClientImpl.connect(ProtonClientOptions options, String host, int port, String username, String password, Handler<AsyncResult<ProtonConnection>> handler)
void	ProtonClientImpl.connect(String host, int port, Handler<AsyncResult<ProtonConnection>> handler)
void	ProtonClientImpl.connect(String host, int port, String username, String password, Handler<AsyncResult<ProtonConnection>> handler)
ProtonServerImpl	ProtonServerImpl.connectHandler(Handler<ProtonConnection> handler)
ProtonConnection	ProtonConnectionImpl.disconnectHandler(Handler<ProtonConnection> disconnectHandler)
ProtonConnection	ProtonConnectionImpl.openHandler(Handler<AsyncResult<ProtonConnection>> openHandler)

Constructor parameters in io.vertx.proton.impl with type arguments of type ProtonConnection

Constructor and Description
ProtonSaslClientAuthenticatorImpl(String username, String password, Set<String> allowedSaslMechanisms, Handler<AsyncResult<ProtonConnection>> handler) Create the authenticator and initialize it.

Uses of ProtonConnection in io.vertx.proton.sasl

Methods in io.vertx.proton.sasl with parameters of type ProtonConnection

Modifier and Type	Method and Description
void	ProtonSaslAuthenticator.init(NetSocket socket, ProtonConnection protonConnection, org.apache.qpid.proton.engine.Transport transport)

Uses of ProtonConnection in io.vertx.proton.streams

Methods in io.vertx.proton.streams with parameters of type ProtonConnection

Modifier and Type	Method and Description
static ProtonPublisher<org.apache.qpid.proton.message.Message>	ProtonStreams.createConsumer(ProtonConnection connection, String address) Creates an AMQP consumer, presented as a reactive streams Publisher.
static ProtonPublisher<org.apache.qpid.proton.message.Message>	ProtonStreams.createConsumer(ProtonConnection connection, String address, ProtonPublisherOptions options) Creates an AMQP consumer, presented as a reactive streams Publisher.
static ProtonPublisher<Delivery>	ProtonStreams.createDeliveryConsumer(ProtonConnection connection, String address) Creates an AMQP consumer, presented as a reactive streams Publisher.
static ProtonPublisher<Delivery>	ProtonStreams.createDeliveryConsumer(ProtonConnection connection, String address, ProtonPublisherOptions options) Creates an AMQP consumer, presented as a reactive streams Publisher.
static ProtonSubscriber<org.apache.qpid.proton.message.Message>	ProtonStreams.createProducer(ProtonConnection connection, String address) Creates an AMQP producer, presented as a reactive streams Subscriber.
static ProtonSubscriber<org.apache.qpid.proton.message.Message>	ProtonStreams.createProducer(ProtonConnection connection, String address, ProtonSubscriberOptions options) Creates an AMQP producer, presented as a reactive streams Subscriber.
static ProtonSubscriber<Tracker>	ProtonStreams.createTrackerProducer(ProtonConnection connection, String address) Creates an AMQP producer, presented as a reactive streams Subscriber.
static ProtonSubscriber<Tracker>	ProtonStreams.createTrackerProducer(ProtonConnection connection, String address, ProtonSubscriberOptions options) Creates an AMQP producer, presented as a reactive streams Subscriber.