Skip navigation links
A B C D E F G H I M P R S T U W 

A

accepted() - Method in interface io.vertx.amqp.AmqpMessage
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message.
addCapability(String) - Method in class io.vertx.amqp.AmqpReceiverOptions
Adds a desired capability.
addCrlPath(String) - Method in class io.vertx.amqp.AmqpClientOptions
 
addCrlValue(Buffer) - Method in class io.vertx.amqp.AmqpClientOptions
 
addEnabledCipherSuite(String) - Method in class io.vertx.amqp.AmqpClientOptions
 
addEnabledSaslMechanism(String) - Method in class io.vertx.amqp.AmqpClientOptions
 
addEnabledSecureTransportProtocol(String) - Method in class io.vertx.amqp.AmqpClientOptions
 
address() - Method in interface io.vertx.amqp.AmqpMessage
 
address(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
address() - Method in interface io.vertx.amqp.AmqpReceiver
The listened address.
address() - Method in interface io.vertx.amqp.AmqpSender
 
AmqpClient - Interface in io.vertx.amqp
AMQP Client entry point.
AmqpClientOptions - Class in io.vertx.amqp
Configures the AMQP Client.
AmqpClientOptions() - Constructor for class io.vertx.amqp.AmqpClientOptions
 
AmqpClientOptions(JsonObject) - Constructor for class io.vertx.amqp.AmqpClientOptions
 
AmqpClientOptions(AmqpClientOptions) - Constructor for class io.vertx.amqp.AmqpClientOptions
 
AmqpClientOptionsConverter - Class in io.vertx.amqp
Converter for AmqpClientOptions.
AmqpClientOptionsConverter() - Constructor for class io.vertx.amqp.AmqpClientOptionsConverter
 
AmqpConnection - Interface in io.vertx.amqp
Once connected to the broker or router, you get a connection.
AmqpMessage - Interface in io.vertx.amqp
Represents an AMQP message.
AmqpMessageBuilder - Interface in io.vertx.amqp
Builder to create a new AmqpMessage.
AmqpReceiver - Interface in io.vertx.amqp
Interface used to consume AMQP message as a stream of message.
AmqpReceiverOptions - Class in io.vertx.amqp
Configures the AMQP Receiver.
AmqpReceiverOptions() - Constructor for class io.vertx.amqp.AmqpReceiverOptions
 
AmqpReceiverOptions(AmqpReceiverOptions) - Constructor for class io.vertx.amqp.AmqpReceiverOptions
 
AmqpReceiverOptions(JsonObject) - Constructor for class io.vertx.amqp.AmqpReceiverOptions
 
AmqpReceiverOptionsConverter - Class in io.vertx.amqp
Converter for AmqpReceiverOptions.
AmqpReceiverOptionsConverter() - Constructor for class io.vertx.amqp.AmqpReceiverOptionsConverter
 
AmqpSender - Interface in io.vertx.amqp
AMQP Sender interface used to send messages.
AmqpSenderOptions - Class in io.vertx.amqp
Configures the AMQP Receiver.
AmqpSenderOptions() - Constructor for class io.vertx.amqp.AmqpSenderOptions
 
AmqpSenderOptions(AmqpSenderOptions) - Constructor for class io.vertx.amqp.AmqpSenderOptions
 
AmqpSenderOptions(JsonObject) - Constructor for class io.vertx.amqp.AmqpSenderOptions
 
AmqpSenderOptionsConverter - Class in io.vertx.amqp
Converter for AmqpSenderOptions.
AmqpSenderOptionsConverter() - Constructor for class io.vertx.amqp.AmqpSenderOptionsConverter
 
applicationProperties() - Method in interface io.vertx.amqp.AmqpMessage
 
applicationProperties(JsonObject) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 

B

bodyAsBinary() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsBoolean() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsByte() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsChar() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsDouble() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsFloat() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsInteger() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsJsonArray() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsJsonObject() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsList() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsLong() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsMap() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsShort() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsString() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsSymbol() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsTimestamp() - Method in interface io.vertx.amqp.AmqpMessage
 
bodyAsUUID() - Method in interface io.vertx.amqp.AmqpMessage
 
build() - Method in interface io.vertx.amqp.AmqpMessageBuilder
 

C

close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.amqp.AmqpClient
Closes the client.
close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.amqp.AmqpConnection
Closes the AMQP connection, i.e.
close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.amqp.AmqpReceiver
Closes the receiver.
close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.amqp.AmqpSender
Closes the sender.
connect(Handler<AsyncResult<AmqpConnection>>) - Method in interface io.vertx.amqp.AmqpClient
Connects to the AMQP broker or router.
connection() - Method in interface io.vertx.amqp.AmqpReceiver
Gets the connection having created the receiver.
connection() - Method in interface io.vertx.amqp.AmqpSender
Gets the connection having created the sender.
contentEncoding() - Method in interface io.vertx.amqp.AmqpMessage
 
contentEncoding(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
contentType() - Method in interface io.vertx.amqp.AmqpMessage
 
contentType(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
correlationId() - Method in interface io.vertx.amqp.AmqpMessage
 
correlationId(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
create(AmqpClientOptions) - Static method in interface io.vertx.amqp.AmqpClient
Creates a new instance of AmqpClient using an internal Vert.x instance (with default configuration) and the given AMQP client configuration.
create(Vertx, AmqpClientOptions) - Static method in interface io.vertx.amqp.AmqpClient
Creates a new instance of AmqpClient with the given Vert.x instance and the given options.
create() - Static method in interface io.vertx.amqp.AmqpMessage
 
create(AmqpMessage) - Static method in interface io.vertx.amqp.AmqpMessage
Creates a builder to create a new AmqpMessage copying the metadata from the passed message.
create(Message) - Static method in interface io.vertx.amqp.AmqpMessage
Creates a builder to create a new AmqpMessage copying the metadata from the passed (Proton) message.
create() - Static method in interface io.vertx.amqp.AmqpMessageBuilder
 
createAnonymousSender(Handler<AsyncResult<AmqpSender>>) - Method in interface io.vertx.amqp.AmqpConnection
Creates an anonymous sender.
createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>>) - Method in interface io.vertx.amqp.AmqpConnection
Creates a dynamic receiver.
createReceiver(String, Handler<AsyncResult<AmqpReceiver>>) - Method in interface io.vertx.amqp.AmqpClient
Creates a receiver used to consume messages from the given address.
createReceiver(String, AmqpReceiverOptions, Handler<AsyncResult<AmqpReceiver>>) - Method in interface io.vertx.amqp.AmqpClient
Creates a receiver used to consumer messages from the given address.
createReceiver(String, Handler<AsyncResult<AmqpReceiver>>) - Method in interface io.vertx.amqp.AmqpConnection
Creates a receiver used to consume messages from the given address.
createReceiver(String, AmqpReceiverOptions, Handler<AsyncResult<AmqpReceiver>>) - Method in interface io.vertx.amqp.AmqpConnection
Creates a receiver used to consumer messages from the given address.
createSender(String, Handler<AsyncResult<AmqpSender>>) - Method in interface io.vertx.amqp.AmqpClient
Creates a sender used to send messages to the given address.
createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>) - Method in interface io.vertx.amqp.AmqpClient
Creates a sender used to send messages to the given address.
createSender(String, Handler<AsyncResult<AmqpSender>>) - Method in interface io.vertx.amqp.AmqpConnection
Creates a sender used to send messages to the given address.
createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>) - Method in interface io.vertx.amqp.AmqpConnection
Creates a sender used to send messages to the given address.
creationTime() - Method in interface io.vertx.amqp.AmqpMessage
 
creationTime(long) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 

D

deliveryCount() - Method in interface io.vertx.amqp.AmqpMessage
 
deliveryCount(int) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
durable(boolean) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 

E

endHandler(Handler<Void>) - Method in interface io.vertx.amqp.AmqpReceiver
 
exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.amqp.AmqpConnection
Registers a handler called on disconnection.
exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.amqp.AmqpReceiver
 
exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.amqp.AmqpSender
 
expiryTime() - Method in interface io.vertx.amqp.AmqpMessage
 
expiryTime(long) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 

F

fetch(long) - Method in interface io.vertx.amqp.AmqpReceiver
 
firstAcquirer(boolean) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
fromJson(Iterable<Map.Entry<String, Object>>, AmqpClientOptions) - Static method in class io.vertx.amqp.AmqpClientOptionsConverter
 
fromJson(Iterable<Map.Entry<String, Object>>, AmqpReceiverOptions) - Static method in class io.vertx.amqp.AmqpReceiverOptionsConverter
 
fromJson(Iterable<Map.Entry<String, Object>>, AmqpSenderOptions) - Static method in class io.vertx.amqp.AmqpSenderOptionsConverter
 

G

getCapabilities() - Method in class io.vertx.amqp.AmqpReceiverOptions
Gets the list of desired capabilities for the source.
getContainerId() - Method in class io.vertx.amqp.AmqpClientOptions
 
getHost() - Method in class io.vertx.amqp.AmqpClientOptions
 
getLinkName() - Method in class io.vertx.amqp.AmqpReceiverOptions
 
getLinkName() - Method in class io.vertx.amqp.AmqpSenderOptions
 
getMaxBufferedMessages() - Method in class io.vertx.amqp.AmqpReceiverOptions
 
getPassword() - Method in class io.vertx.amqp.AmqpClientOptions
 
getPort() - Method in class io.vertx.amqp.AmqpClientOptions
 
getQos() - Method in class io.vertx.amqp.AmqpReceiverOptions
Gets the local QOS config, values can be null, AT_MOST_ONCE or AT_LEAST_ONCE.
getUsername() - Method in class io.vertx.amqp.AmqpClientOptions
 
groupId() - Method in interface io.vertx.amqp.AmqpMessage
 
groupId(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
groupSequence() - Method in interface io.vertx.amqp.AmqpMessage
 

H

handler(Handler<AmqpMessage>) - Method in interface io.vertx.amqp.AmqpReceiver
 

I

id() - Method in interface io.vertx.amqp.AmqpMessage
 
id(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
io.vertx.amqp - package io.vertx.amqp
 
isAutoAcknowledgement() - Method in class io.vertx.amqp.AmqpReceiverOptions
 
isAutoDrained() - Method in class io.vertx.amqp.AmqpSenderOptions
Get whether the link will automatically be marked drained after the send queue drain handler fires in drain mode.
isBodyNull() - Method in interface io.vertx.amqp.AmqpMessage
 
isDurable() - Method in interface io.vertx.amqp.AmqpMessage
 
isDurable() - Method in class io.vertx.amqp.AmqpReceiverOptions
 
isDynamic() - Method in class io.vertx.amqp.AmqpReceiverOptions
 
isDynamic() - Method in class io.vertx.amqp.AmqpSenderOptions
 
isFirstAcquirer() - Method in interface io.vertx.amqp.AmqpMessage
 

M

modified(boolean, boolean) - Method in interface io.vertx.amqp.AmqpMessage
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as modified.

P

pause() - Method in interface io.vertx.amqp.AmqpReceiver
 
priority() - Method in interface io.vertx.amqp.AmqpMessage
 
priority(short) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 

R

rejected() - Method in interface io.vertx.amqp.AmqpMessage
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as rejected.
released() - Method in interface io.vertx.amqp.AmqpMessage
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as released.
removeEnabledSecureTransportProtocol(String) - Method in class io.vertx.amqp.AmqpClientOptions
 
replyTo() - Method in interface io.vertx.amqp.AmqpMessage
 
replyTo(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
replyToGroupId() - Method in interface io.vertx.amqp.AmqpMessage
 
replyToGroupId(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
resume() - Method in interface io.vertx.amqp.AmqpReceiver
 

S

send(AmqpMessage) - Method in interface io.vertx.amqp.AmqpSender
Sends an AMQP message.
sendWithAck(AmqpMessage, Handler<AsyncResult<Void>>) - Method in interface io.vertx.amqp.AmqpSender
Sends an AMQP message and waits for an acknowledgement.
setAutoAcknowledgement(boolean) - Method in class io.vertx.amqp.AmqpReceiverOptions
Sets the auto-acknowledgement.
setAutoDrained(boolean) - Method in class io.vertx.amqp.AmqpSenderOptions
Sets whether the link is automatically marked drained after the send queue drain handler callback returns if the receiving peer requested that credit be drained.
setCapabilities(List<String>) - Method in class io.vertx.amqp.AmqpReceiverOptions
Sets the list of desired capabilities A registry of commonly defined source capabilities and their meanings is maintained at AMQP Source Capabilities.
setConnectTimeout(int) - Method in class io.vertx.amqp.AmqpClientOptions
 
setContainerId(String) - Method in class io.vertx.amqp.AmqpClientOptions
Sets the container id.
setDurable(boolean) - Method in class io.vertx.amqp.AmqpReceiverOptions
Sets the durability.
setDynamic(boolean) - Method in class io.vertx.amqp.AmqpReceiverOptions
Sets whether the link remote terminus to be used should indicate it is 'dynamic', requesting the peer names it with a dynamic address.
setDynamic(boolean) - Method in class io.vertx.amqp.AmqpSenderOptions
Sets whether the link remote terminus to be used should indicate it is 'dynamic', requesting the peer names it with a dynamic address.
setEnabledSecureTransportProtocols(Set<String>) - Method in class io.vertx.amqp.AmqpClientOptions
 
setHeartbeat(int) - Method in class io.vertx.amqp.AmqpClientOptions
 
setHost(String) - Method in class io.vertx.amqp.AmqpClientOptions
Sets the host.
setHostnameVerificationAlgorithm(String) - Method in class io.vertx.amqp.AmqpClientOptions
 
setIdleTimeout(int) - Method in class io.vertx.amqp.AmqpClientOptions
 
setJdkSslEngineOptions(JdkSSLEngineOptions) - Method in class io.vertx.amqp.AmqpClientOptions
 
setKeyStoreOptions(JksOptions) - Method in class io.vertx.amqp.AmqpClientOptions
 
setLinkName(String) - Method in class io.vertx.amqp.AmqpReceiverOptions
 
setLinkName(String) - Method in class io.vertx.amqp.AmqpSenderOptions
 
setLocalAddress(String) - Method in class io.vertx.amqp.AmqpClientOptions
 
setMaxBufferedMessages(int) - Method in class io.vertx.amqp.AmqpReceiverOptions
Sets the max buffered messages.
setMaxFrameSize(int) - Method in class io.vertx.amqp.AmqpClientOptions
 
setOpenSslEngineOptions(OpenSSLEngineOptions) - Method in class io.vertx.amqp.AmqpClientOptions
 
setPassword(String) - Method in class io.vertx.amqp.AmqpClientOptions
Sets the password.
setPemKeyCertOptions(PemKeyCertOptions) - Method in class io.vertx.amqp.AmqpClientOptions
 
setPemTrustOptions(PemTrustOptions) - Method in class io.vertx.amqp.AmqpClientOptions
 
setPfxKeyCertOptions(PfxOptions) - Method in class io.vertx.amqp.AmqpClientOptions
 
setPfxTrustOptions(PfxOptions) - Method in class io.vertx.amqp.AmqpClientOptions
 
setPort(int) - Method in class io.vertx.amqp.AmqpClientOptions
Sets the port.
setQos(String) - Method in class io.vertx.amqp.AmqpReceiverOptions
Sets the local QOS config.
setReceiveBufferSize(int) - Method in class io.vertx.amqp.AmqpClientOptions
 
setReconnectAttempts(int) - Method in class io.vertx.amqp.AmqpClientOptions
 
setReconnectInterval(long) - Method in class io.vertx.amqp.AmqpClientOptions
 
setReuseAddress(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setReusePort(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setSendBufferSize(int) - Method in class io.vertx.amqp.AmqpClientOptions
 
setSniServerName(String) - Method in class io.vertx.amqp.AmqpClientOptions
 
setSoLinger(int) - Method in class io.vertx.amqp.AmqpClientOptions
 
setSsl(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setSslEngineOptions(SSLEngineOptions) - Method in class io.vertx.amqp.AmqpClientOptions
 
setTcpCork(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setTcpFastOpen(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setTcpKeepAlive(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setTcpNoDelay(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setTcpQuickAck(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setTrafficClass(int) - Method in class io.vertx.amqp.AmqpClientOptions
 
setTrustAll(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setTrustStoreOptions(JksOptions) - Method in class io.vertx.amqp.AmqpClientOptions
 
setUsePooledBuffers(boolean) - Method in class io.vertx.amqp.AmqpClientOptions
 
setUsername(String) - Method in class io.vertx.amqp.AmqpClientOptions
Sets the username.
setVirtualHost(String) - Method in class io.vertx.amqp.AmqpClientOptions
 
setWriteQueueMaxSize(int) - Method in interface io.vertx.amqp.AmqpSender
 
subject() - Method in interface io.vertx.amqp.AmqpMessage
 
subject(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 

T

toJson() - Method in class io.vertx.amqp.AmqpClientOptions
 
toJson(AmqpClientOptions, JsonObject) - Static method in class io.vertx.amqp.AmqpClientOptionsConverter
 
toJson(AmqpClientOptions, Map<String, Object>) - Static method in class io.vertx.amqp.AmqpClientOptionsConverter
 
toJson() - Method in class io.vertx.amqp.AmqpReceiverOptions
 
toJson(AmqpReceiverOptions, JsonObject) - Static method in class io.vertx.amqp.AmqpReceiverOptionsConverter
 
toJson(AmqpReceiverOptions, Map<String, Object>) - Static method in class io.vertx.amqp.AmqpReceiverOptionsConverter
 
toJson() - Method in class io.vertx.amqp.AmqpSenderOptions
 
toJson(AmqpSenderOptions, JsonObject) - Static method in class io.vertx.amqp.AmqpSenderOptionsConverter
 
toJson(AmqpSenderOptions, Map<String, Object>) - Static method in class io.vertx.amqp.AmqpSenderOptionsConverter
 
ttl() - Method in interface io.vertx.amqp.AmqpMessage
 
ttl(long) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 

U

unwrap() - Method in interface io.vertx.amqp.AmqpMessage
 

W

withBody(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withBooleanAsBody(boolean) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withBufferAsBody(Buffer) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withByteAsBody(byte) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withCharAsBody(char) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withDoubleAsBody(double) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withFloatAsBody(float) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withInstantAsBody(Instant) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withIntegerAsBody(int) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withJsonArrayAsBody(JsonArray) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withJsonObjectAsBody(JsonObject) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withListAsBody(List) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withLongAsBody(long) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withMapAsBody(Map) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withShortAsBody(short) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withSymbolAsBody(String) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
withUuidAsBody(UUID) - Method in interface io.vertx.amqp.AmqpMessageBuilder
 
write(AmqpMessage) - Method in interface io.vertx.amqp.AmqpSender
 
write(AmqpMessage, Handler<AsyncResult<Void>>) - Method in interface io.vertx.amqp.AmqpSender
 
A B C D E F G H I M P R S T U W 
Skip navigation links

Copyright © 2020 Eclipse. All rights reserved.