- close() - Method in interface io.vertx.proton.ProtonConnection
-
Closes the AMQP connection, i.e.
- close() - Method in interface io.vertx.proton.ProtonLink
-
Closes the AMQP link, i.e.
- close() - Method in interface io.vertx.proton.ProtonServer
-
Closes the server and any currently open connections.
- close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.proton.ProtonServer
-
Closes the server and any currently open connections, notifying the given handler when complete.
- close() - Method in interface io.vertx.proton.ProtonSession
-
Closed the AMQP session, i.e.
- closeHandler(Handler<AsyncResult<ProtonConnection>>) - Method in interface io.vertx.proton.ProtonConnection
-
Sets a handler for when an AMQP Close frame is received from the remote peer.
- closeHandler(Handler<AsyncResult<T>>) - Method in interface io.vertx.proton.ProtonLink
-
Sets a handler for when an AMQP Detach frame with closed=true is received from the remote peer.
- closeHandler(Handler<AsyncResult<ProtonSession>>) - Method in interface io.vertx.proton.ProtonSession
-
Sets a handler for when an AMQP End frame is received from the remote peer.
- condition(Symbol, String) - Static method in interface io.vertx.proton.ProtonHelper
-
Create an ErrorCondition with the given error condition value and error description string.
- condition(String, String) - Static method in interface io.vertx.proton.ProtonHelper
-
Create an ErrorCondition with the given error condition value (which will be converted to the required Symbol type)
and error description string.
- connect(String, int, Handler<AsyncResult<ProtonConnection>>) - Method in interface io.vertx.proton.ProtonClient
-
Connect to the given host and port, without credentials.
- connect(String, int, String, String, Handler<AsyncResult<ProtonConnection>>) - Method in interface io.vertx.proton.ProtonClient
-
Connect to the given host and port, with credentials (if required by server peer).
- connect(ProtonClientOptions, String, int, Handler<AsyncResult<ProtonConnection>>) - Method in interface io.vertx.proton.ProtonClient
-
Connect to the given host and port, without credentials.
- connect(ProtonClientOptions, String, int, String, String, Handler<AsyncResult<ProtonConnection>>) - Method in interface io.vertx.proton.ProtonClient
-
Connect to the given host and port, with credentials (if required by server peer).
- connectHandler(Handler<ProtonConnection>) - Method in interface io.vertx.proton.ProtonServer
-
The handler called when a new client connection is accepted.
- connectHandler() - Method in interface io.vertx.proton.ProtonServer
-
Returns the current connectHandler.
- create(Vertx) - Static method in interface io.vertx.proton.ProtonClient
-
Create a ProtonClient instance with the given Vertx instance.
- create(Vertx) - Static method in interface io.vertx.proton.ProtonServer
-
Create a ProtonServer instance with the given Vertx instance.
- create(Vertx, ProtonServerOptions) - Static method in interface io.vertx.proton.ProtonServer
-
Create a ProtonServer instance with the given Vertx instance and options.
- create() - Method in interface io.vertx.proton.sasl.ProtonSaslAuthenticatorFactory
-
Create a ProtonSaslAuthenticator for use with a connection.
- createMechanism() - Method in interface io.vertx.proton.sasl.ProtonSaslMechanismFactory
-
Creates an instance of the authentication mechanism implementation.
- createReceiver(String) - Method in interface io.vertx.proton.ProtonConnection
-
Creates a receiver used to consumer messages from the given node address.
- createReceiver(String, ProtonLinkOptions) - Method in interface io.vertx.proton.ProtonConnection
-
Creates a receiver used to consumer messages from the given node address.
- createReceiver(String) - Method in interface io.vertx.proton.ProtonSession
-
Creates a receiver used to consumer messages from the given node address.
- createReceiver(String, ProtonLinkOptions) - Method in interface io.vertx.proton.ProtonSession
-
Creates a receiver used to consumer messages from the given node address.
- createSender(String) - Method in interface io.vertx.proton.ProtonConnection
-
Creates a sender used to send messages to the given node address.
- createSender(String, ProtonLinkOptions) - Method in interface io.vertx.proton.ProtonConnection
-
Creates a sender used to send messages to the given node address.
- createSender(String) - Method in interface io.vertx.proton.ProtonSession
-
Creates a sender used to send messages to the given node address.
- createSender(String, ProtonLinkOptions) - Method in interface io.vertx.proton.ProtonSession
-
Creates a sender used to send messages to the given node address.
- createSession() - Method in interface io.vertx.proton.ProtonConnection
-
Creates a new session, which can be used to create new senders/receivers on.
- getChallengeResponse(byte[]) - Method in interface io.vertx.proton.sasl.ProtonSaslMechanism
-
Create a response based on a given challenge from the remote peer.
- getCondition() - Method in interface io.vertx.proton.ProtonConnection
-
Gets the local ErrorCondition object.
- getCondition() - Method in interface io.vertx.proton.ProtonLink
-
Gets the local ErrorCondition object.
- getCondition() - Method in interface io.vertx.proton.ProtonSession
-
Gets the local ErrorCondition object.
- getConnection() - Method in interface io.vertx.proton.ProtonSession
-
Gets the connection this session is on.
- getContainer() - Method in interface io.vertx.proton.ProtonConnection
-
Gets the container id value requested of/advertised to peers in the AMQP Open frame.
- getCredit() - Method in interface io.vertx.proton.ProtonLink
-
Retrieves the current amount of credit.
- getDrain() - Method in interface io.vertx.proton.ProtonLink
-
Retrieves the current value of link 'drain' flag.
- getEnabledSaslMechanisms() - Method in class io.vertx.proton.ProtonClientOptions
-
Get the mechanisms the client should be restricted to use.
- getHeartbeat() - Method in class io.vertx.proton.ProtonClientOptions
-
Return the heartbeat (in milliseconds) as maximum delay between sending frames for the remote peers.
- getHeartbeat() - Method in class io.vertx.proton.ProtonServerOptions
-
Return the heartbeat (in milliseconds) as maximum delay between sending frames for the remote peers.
- getHeartbeat() - Method in class io.vertx.proton.ProtonTransportOptions
-
Return the heartbeat as maximum delay between sending frames for the remote peers.
- getHostname() - Method in interface io.vertx.proton.ProtonConnection
-
Gets the hostname value requested of/advertised to peers in the AMQP Open frame.
- getIncomingCapacity() - Method in interface io.vertx.proton.ProtonSession
-
Gets the incoming capacity in bytes, used to govern session-level flow control.
- getInitialResponse() - Method in interface io.vertx.proton.sasl.ProtonSaslMechanism
-
Create an initial response based on selected mechanism.
- getLinkName() - Method in class io.vertx.proton.ProtonLinkOptions
-
- getLocalState() - Method in interface io.vertx.proton.ProtonDelivery
-
Gets the current local state for the delivery.
- getMaxMessageSize() - Method in interface io.vertx.proton.ProtonLink
-
Gets the local link max message size.
- getMechanismName() - Method in interface io.vertx.proton.sasl.ProtonSaslMechanismFactory
-
Get the name of the mechanism supported by the factory
- getMessageFormat() - Method in interface io.vertx.proton.ProtonDelivery
-
Gets the message format for the current delivery.
- getName() - Method in interface io.vertx.proton.ProtonLink
-
Retrieves the link name
- getName() - Method in interface io.vertx.proton.sasl.ProtonSaslMechanism
-
- getPassword() - Method in interface io.vertx.proton.sasl.ProtonSaslMechanism
-
Returns the configured password value for this Mechanism.
- getPrefetch() - Method in interface io.vertx.proton.ProtonReceiver
-
Get the current prefetch value.
- getPriority() - Method in interface io.vertx.proton.sasl.ProtonSaslMechanism
-
- getQoS() - Method in interface io.vertx.proton.ProtonLink
-
Gets the local QOS config.
- getQueued() - Method in interface io.vertx.proton.ProtonLink
-
Retrieves the current number of queued messages.
- getRemoteCondition() - Method in interface io.vertx.proton.ProtonConnection
-
Gets the remote ErrorCondition object.
- getRemoteCondition() - Method in interface io.vertx.proton.ProtonLink
-
Gets the remote ErrorCondition object.
- getRemoteCondition() - Method in interface io.vertx.proton.ProtonSession
-
Gets the remote ErrorCondition object.
- getRemoteContainer() - Method in interface io.vertx.proton.ProtonConnection
-
Returns the container value requested by/advertised by remote peer in their AMQP Open frame.
- getRemoteHostname() - Method in interface io.vertx.proton.ProtonConnection
-
Returns the container value requested by/advertised by remote peer in their AMQP Open frame.
- getRemoteMaxMessageSize() - Method in interface io.vertx.proton.ProtonLink
-
Gets the remote link max message size, as conveyed from the peer via the Attach frame
when attaching the link to the session.
- getRemoteProperties() - Method in interface io.vertx.proton.ProtonConnection
-
Returns the connection properties map if sent by the remote peer in its Open frame.
- getRemoteQoS() - Method in interface io.vertx.proton.ProtonLink
-
Gets the remote QOS config.
- getRemoteSource() - Method in interface io.vertx.proton.ProtonLink
-
Gets the current remote source config.
- getRemoteState() - Method in interface io.vertx.proton.ProtonDelivery
-
Gets the current remote state for the delivery.
- getRemoteTarget() - Method in interface io.vertx.proton.ProtonLink
-
Gets the current remote target config.
- getSession() - Method in interface io.vertx.proton.ProtonLink
-
Gets the session this link is on.
- getSniServerName() - Method in class io.vertx.proton.ProtonClientOptions
-
- getSource() - Method in interface io.vertx.proton.ProtonLink
-
Gets the current local source config.
- getTag() - Method in interface io.vertx.proton.ProtonDelivery
-
Gets the delivery tag for this delivery
- getTarget() - Method in interface io.vertx.proton.ProtonLink
-
Gets the current local target config.
- getUsername() - Method in interface io.vertx.proton.sasl.ProtonSaslMechanism
-
Returns the configured user name value for this Mechanism.
- getValue() - Method in enum io.vertx.proton.sasl.ProtonSaslMechanism.PRIORITY
-
- getVirtualHost() - Method in class io.vertx.proton.ProtonClientOptions
-
- saslAuthenticatorFactory(ProtonSaslAuthenticatorFactory) - Method in interface io.vertx.proton.ProtonServer
-
Sets the authenticator factory to be used by the server.
- send(Message) - Method in interface io.vertx.proton.ProtonSender
-
Send the given message.
- send(Message, Handler<ProtonDelivery>) - Method in interface io.vertx.proton.ProtonSender
-
Send the given message, registering the given handler to be called whenever the related delivery is updated due to
receiving disposition frames from the peer.
- send(byte[], Message) - Method in interface io.vertx.proton.ProtonSender
-
Send the given message, using the supplied delivery tag when creating the delivery.
- send(byte[], Message, Handler<ProtonDelivery>) - Method in interface io.vertx.proton.ProtonSender
-
Send the given message, using the supplied delivery tag when creating the delivery, and registering the given
handler to be called whenever the related delivery is updated due to receiving disposition frames from the peer.
- senderOpenHandler(Handler<ProtonSender>) - Method in interface io.vertx.proton.ProtonConnection
-
Sets a handler for when an AMQP Attach frame is received from the remote peer for a sending link.
- sendQueueDrainHandler(Handler<ProtonSender>) - Method in interface io.vertx.proton.ProtonSender
-
Sets a handler called when the send queue is not full, i.e.
- sendQueueFull() - Method in interface io.vertx.proton.ProtonSender
-
Gets whether the senders outgoing send queue is full, i.e.
- sessionOpenHandler(Handler<ProtonSession>) - Method in interface io.vertx.proton.ProtonConnection
-
Sets a handler for when an AMQP Begin frame is received from the remote peer.
- setAcceptBacklog(int) - Method in class io.vertx.proton.ProtonServerOptions
-
- setAutoAccept(boolean) - Method in interface io.vertx.proton.ProtonReceiver
-
Sets whether received deliveries should be automatically accepted (and settled) after the message handler runs for
them, if no other disposition has been applied during handling.
- setAutoDrained(boolean) - Method in interface io.vertx.proton.ProtonSender
-
Sets whether the link is automatically marked
ProtonSender.drained()
after the send queue drain handler callback
returns if the receiving peer requested that credit be drained, as indicated by the value of the
ProtonLink.getDrain()
flag.
- setAutoSettle(boolean) - Method in interface io.vertx.proton.ProtonSender
-
Sets whether sent deliveries should be automatically locally-settled once they have become remotely-settled by the
receiving peer.
- setClientAuth(ClientAuth) - Method in class io.vertx.proton.ProtonServerOptions
-
- setClientAuthRequired(boolean) - Method in class io.vertx.proton.ProtonServerOptions
-
Deprecated.
- setCondition(ErrorCondition) - Method in interface io.vertx.proton.ProtonConnection
-
Sets the local ErrorCondition object.
- setCondition(ErrorCondition) - Method in interface io.vertx.proton.ProtonLink
-
Sets the local ErrorCondition object.
- setCondition(ErrorCondition) - Method in interface io.vertx.proton.ProtonSession
-
Sets the local ErrorCondition object.
- setConnectTimeout(int) - Method in class io.vertx.proton.ProtonClientOptions
-
- setContainer(String) - Method in interface io.vertx.proton.ProtonConnection
-
Sets the container id value advertised to peers in the AMQP Open frame.
- setHeartbeat(int) - Method in class io.vertx.proton.ProtonClientOptions
-
Set the heartbeat (in milliseconds) as maximum delay between sending frames for the remote peers.
- setHeartbeat(int) - Method in class io.vertx.proton.ProtonServerOptions
-
Set the heartbeat (in milliseconds) as maximum delay between sending frames for the remote peers.
- setHeartbeat(int) - Method in class io.vertx.proton.ProtonTransportOptions
-
Set the heartbeat as maximum delay between sending frames for the remote peers.
- setHost(String) - Method in class io.vertx.proton.ProtonServerOptions
-
- setHostname(String) - Method in interface io.vertx.proton.ProtonConnection
-
Sets the hostname value requested of/advertised to peers in the AMQP Open frame.
- setHostnameVerificationAlgorithm(String) - Method in class io.vertx.proton.ProtonClientOptions
-
- setIdleTimeout(int) - Method in class io.vertx.proton.ProtonClientOptions
-
- setIdleTimeout(int) - Method in class io.vertx.proton.ProtonServerOptions
-
- setIncomingCapacity(int) - Method in interface io.vertx.proton.ProtonSession
-
Sets the incoming capacity in bytes, used to govern session-level flow control.
- setJdkSslEngineOptions(JdkSSLEngineOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setJdkSslEngineOptions(JdkSSLEngineOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setKeyCertOptions(KeyCertOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setKeyCertOptions(KeyCertOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setKeyStoreOptions(JksOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setKeyStoreOptions(JksOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setLinkName(String) - Method in class io.vertx.proton.ProtonLinkOptions
-
- setLocalAddress(String) - Method in class io.vertx.proton.ProtonClientOptions
-
- setLogActivity(boolean) - Method in class io.vertx.proton.ProtonClientOptions
-
- setLogActivity(boolean) - Method in class io.vertx.proton.ProtonServerOptions
-
- setMaxMessageSize(UnsignedLong) - Method in interface io.vertx.proton.ProtonLink
-
Sets the local link max message size, to be conveyed to the peer via the Attach frame
when attaching the link to the session.
- setMetricsName(String) - Method in class io.vertx.proton.ProtonClientOptions
-
- setOpenSslEngineOptions(OpenSSLEngineOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setOpenSslEngineOptions(OpenSSLEngineOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setPassword(String) - Method in interface io.vertx.proton.sasl.ProtonSaslMechanism
-
Sets the password value for this Mechanism.
- setPemKeyCertOptions(PemKeyCertOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setPemKeyCertOptions(PemKeyCertOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setPemTrustOptions(PemTrustOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setPemTrustOptions(PemTrustOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setPfxKeyCertOptions(PfxOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setPfxKeyCertOptions(PfxOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setPfxTrustOptions(PfxOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setPfxTrustOptions(PfxOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setPort(int) - Method in class io.vertx.proton.ProtonServerOptions
-
- setPrefetch(int) - Method in interface io.vertx.proton.ProtonReceiver
-
Sets the number of message credits the receiver grants and replenishes automatically as messages are delivered.
- setProperties(Map<Symbol, Object>) - Method in interface io.vertx.proton.ProtonConnection
-
Sets the connection properties map to be sent to the remote peer in our Open frame.
- setProxyOptions(ProxyOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setQoS(ProtonQoS) - Method in interface io.vertx.proton.ProtonLink
-
Sets the local QOS config.
- setReceiveBufferSize(int) - Method in class io.vertx.proton.ProtonClientOptions
-
- setReceiveBufferSize(int) - Method in class io.vertx.proton.ProtonServerOptions
-
- setReconnectAttempts(int) - Method in class io.vertx.proton.ProtonClientOptions
-
- setReconnectInterval(long) - Method in class io.vertx.proton.ProtonClientOptions
-
- setReuseAddress(boolean) - Method in class io.vertx.proton.ProtonClientOptions
-
- setReuseAddress(boolean) - Method in class io.vertx.proton.ProtonServerOptions
-
- setSendBufferSize(int) - Method in class io.vertx.proton.ProtonClientOptions
-
- setSendBufferSize(int) - Method in class io.vertx.proton.ProtonServerOptions
-
- setSni(boolean) - Method in class io.vertx.proton.ProtonServerOptions
-
- setSniServerName(String) - Method in class io.vertx.proton.ProtonClientOptions
-
Explicitly override the hostname to use for the TLS SNI server name.
- setSoLinger(int) - Method in class io.vertx.proton.ProtonClientOptions
-
- setSoLinger(int) - Method in class io.vertx.proton.ProtonServerOptions
-
- setSource(Source) - Method in interface io.vertx.proton.ProtonLink
-
Sets the current local source config.
- setSsl(boolean) - Method in class io.vertx.proton.ProtonClientOptions
-
- setSsl(boolean) - Method in class io.vertx.proton.ProtonServerOptions
-
- setSslEngineOptions(SSLEngineOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setSslEngineOptions(SSLEngineOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setTarget(Target) - Method in interface io.vertx.proton.ProtonLink
-
Sets the current local target config.
- setTcpKeepAlive(boolean) - Method in class io.vertx.proton.ProtonClientOptions
-
- setTcpKeepAlive(boolean) - Method in class io.vertx.proton.ProtonServerOptions
-
- setTcpNoDelay(boolean) - Method in class io.vertx.proton.ProtonClientOptions
-
- setTcpNoDelay(boolean) - Method in class io.vertx.proton.ProtonServerOptions
-
- settle() - Method in interface io.vertx.proton.ProtonDelivery
-
Settles the delivery locally.
- setTrafficClass(int) - Method in class io.vertx.proton.ProtonClientOptions
-
- setTrafficClass(int) - Method in class io.vertx.proton.ProtonServerOptions
-
- setTrustAll(boolean) - Method in class io.vertx.proton.ProtonClientOptions
-
- setTrustOptions(TrustOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setTrustOptions(TrustOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setTrustStoreOptions(JksOptions) - Method in class io.vertx.proton.ProtonClientOptions
-
- setTrustStoreOptions(JksOptions) - Method in class io.vertx.proton.ProtonServerOptions
-
- setUseAlpn(boolean) - Method in class io.vertx.proton.ProtonClientOptions
-
- setUseAlpn(boolean) - Method in class io.vertx.proton.ProtonServerOptions
-
- setUsePooledBuffers(boolean) - Method in class io.vertx.proton.ProtonClientOptions
-
- setUsePooledBuffers(boolean) - Method in class io.vertx.proton.ProtonServerOptions
-
- setUsername(String) - Method in interface io.vertx.proton.sasl.ProtonSaslMechanism
-
Sets the user name value for this Mechanism.
- setVirtualHost(String) - Method in class io.vertx.proton.ProtonClientOptions
-
Override the hostname value used in the connection AMQP Open frame and TLS SNI server name (if TLS is in use).
- succeeded() - Method in interface io.vertx.proton.sasl.ProtonSaslAuthenticator
-
Once called after process finished it returns true if the authentication succeeded.