Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.fasterxml.jackson.core/jackson-annotations/2.9.0
- com.fasterxml.jackson.core/jackson-core/2.9.9
- com.fasterxml.jackson.core/jackson-databind/2.9.9.1
- com.github.jponge/lzma-java/1.3
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.jcraft/jzlib/1.1.3
- commons-logging/commons-logging/1.2
- com.ning/compress-lzf/1.0.3
- com.sun/tools/1.8
- io.netty/netty-buffer/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- io.vertx/vertx-proton/3.8.0
- java/11
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- net.jpountz.lz4/lz4/1.3.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.apache.qpid/proton-j/0.33.1
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk15on/1.54
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.mvel/mvel2/2.3.1.Final
- org.slf4j/slf4j-api/1.7.21
Declarations
-
examples
-
AmqpClientExamples
-
creation(Vertx): void
-
connect(AmqpClient): void
-
receiver1(AmqpConnection): void
-
receiverFromClient(AmqpClient): void
-
senderFromClient(AmqpClient): void
-
receiver2(AmqpConnection): void
-
sender(AmqpConnection): void
-
messages(): void
-
send(AmqpSender): void
-
sendWithAck(AmqpSender): void
-
requestReply(AmqpConnection): void
-
-
-
io
-
vertx
-
amqp
-
AmqpClient
-
create(AmqpClientOptions): AmqpClient
-
create(Vertx, AmqpClientOptions): AmqpClient
-
connect(Handler<AsyncResult<AmqpConnection>>): AmqpClient
-
close(Handler<AsyncResult<Void>>): void
-
createReceiver(String, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
-
createReceiver(String, Handler<AmqpMessage>, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
-
createReceiver(String, AmqpReceiverOptions, Handler<AmqpMessage>, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
-
createSender(String, Handler<AsyncResult<AmqpSender>>): AmqpClient
-
createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>): AmqpClient
-
-
AmqpClientOptions
-
host: String
-
port: int
-
username: String
-
password: String
-
containerId: String
-
AmqpClientOptions(): void
-
AmqpClientOptions(JsonObject): void
-
AmqpClientOptions(AmqpClientOptions): void
-
toJson(): JsonObject
-
getHost(): String
-
setHost(String): AmqpClientOptions
-
getPort(): int
-
setPort(int): AmqpClientOptions
-
getUsername(): String
-
setUsername(String): AmqpClientOptions
-
getPassword(): String
-
setPassword(String): AmqpClientOptions
-
getContainerId(): String
-
setContainerId(String): AmqpClientOptions
-
addEnabledSaslMechanism(String): AmqpClientOptions
-
setSendBufferSize(int): AmqpClientOptions
-
setReceiveBufferSize(int): AmqpClientOptions
-
setReuseAddress(boolean): AmqpClientOptions
-
setTrafficClass(int): AmqpClientOptions
-
setTcpNoDelay(boolean): AmqpClientOptions
-
setTcpKeepAlive(boolean): AmqpClientOptions
-
setSoLinger(int): AmqpClientOptions
-
setUsePooledBuffers(boolean): AmqpClientOptions
-
setIdleTimeout(int): AmqpClientOptions
-
setSsl(boolean): AmqpClientOptions
-
setKeyStoreOptions(JksOptions): AmqpClientOptions
-
setPfxKeyCertOptions(PfxOptions): AmqpClientOptions
-
setPemKeyCertOptions(PemKeyCertOptions): AmqpClientOptions
-
setTrustStoreOptions(JksOptions): AmqpClientOptions
-
setPemTrustOptions(PemTrustOptions): AmqpClientOptions
-
setPfxTrustOptions(PfxOptions): AmqpClientOptions
-
addEnabledCipherSuite(String): AmqpClientOptions
-
addCrlPath(String): AmqpClientOptions
-
addCrlValue(Buffer): AmqpClientOptions
-
setTrustAll(boolean): AmqpClientOptions
-
setConnectTimeout(int): AmqpClientOptions
-
setReconnectAttempts(int): AmqpClientOptions
-
setReconnectInterval(long): AmqpClientOptions
-
addEnabledSecureTransportProtocol(String): AmqpClientOptions
-
setHostnameVerificationAlgorithm(String): AmqpClientOptions
-
setJdkSslEngineOptions(JdkSSLEngineOptions): AmqpClientOptions
-
setOpenSslEngineOptions(OpenSSLEngineOptions): AmqpClientOptions
-
setSslEngineOptions(SSLEngineOptions): AmqpClientOptions
-
setLocalAddress(String): AmqpClientOptions
-
setReusePort(boolean): AmqpClientOptions
-
setTcpCork(boolean): AmqpClientOptions
-
setTcpFastOpen(boolean): AmqpClientOptions
-
setTcpQuickAck(boolean): AmqpClientOptions
-
removeEnabledSecureTransportProtocol(String): AmqpClientOptions
-
setEnabledSecureTransportProtocols(Set<String>): AmqpClientOptions
-
setVirtualHost(String): AmqpClientOptions
-
setSniServerName(String): AmqpClientOptions
-
setHeartbeat(int): AmqpClientOptions
-
setMaxFrameSize(int): AmqpClientOptions
-
getFromSysOrEnv(String): String
-
getPortFromSysOrEnv(): int
-
-
AmqpClientOptionsConverter
-
AmqpConnection
-
exceptionHandler(Handler<Throwable>): AmqpConnection
-
close(Handler<AsyncResult<Void>>): AmqpConnection
-
createReceiver(String, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
createReceiver(String, Handler<AmqpMessage>, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
createReceiver(String, AmqpReceiverOptions, Handler<AmqpMessage>, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
createReceiver(String, AmqpReceiverOptions, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
createSender(String, Handler<AsyncResult<AmqpSender>>): AmqpConnection
-
createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>): AmqpConnection
-
createAnonymousSender(Handler<AsyncResult<AmqpSender>>): AmqpConnection
-
-
AmqpMessage
-
rejected(): AmqpMessage
-
correlationId(): String
-
isBodyNull(): boolean
-
released(): AmqpMessage
-
create(): AmqpMessageBuilder
-
create(AmqpMessage): AmqpMessageBuilder
-
create(Message): AmqpMessageBuilder
-
isDurable(): boolean
-
isFirstAcquirer(): boolean
-
priority(): int
-
deliveryCount(): int
-
ttl(): long
-
id(): String
-
address(): String
-
replyTo(): String
-
bodyAsBoolean(): boolean
-
bodyAsByte(): byte
-
bodyAsShort(): short
-
bodyAsInteger(): int
-
bodyAsLong(): long
-
bodyAsFloat(): float
-
bodyAsDouble(): double
-
bodyAsChar(): char
-
bodyAsTimestamp(): Instant
-
bodyAsUUID(): UUID
-
bodyAsBinary(): Buffer
-
bodyAsString(): String
-
bodyAsSymbol(): String
-
bodyAsList(): List<Object>
-
bodyAsMap(): Map<Object, Object>
-
bodyAsJsonObject(): JsonObject
-
bodyAsJsonArray(): JsonArray
-
subject(): String
-
contentType(): String
-
contentEncoding(): String
-
expiryTime(): long
-
creationTime(): long
-
groupId(): String
-
replyToGroupId(): String
-
groupSequence(): long
-
applicationProperties(): JsonObject
-
unwrap(): Message
-
accepted(): AmqpMessage
-
modified(boolean, boolean): AmqpMessage
-
-
AmqpMessageBuilder
-
create(): AmqpMessageBuilder
-
build(): AmqpMessage
-
priority(short): AmqpMessageBuilder
-
durable(boolean): AmqpMessageBuilder
-
ttl(long): AmqpMessageBuilder
-
firstAcquirer(boolean): AmqpMessageBuilder
-
deliveryCount(int): AmqpMessageBuilder
-
id(String): AmqpMessageBuilder
-
address(String): AmqpMessageBuilder
-
replyTo(String): AmqpMessageBuilder
-
correlationId(String): AmqpMessageBuilder
-
withBody(String): AmqpMessageBuilder
-
withSymbolAsBody(String): AmqpMessageBuilder
-
subject(String): AmqpMessageBuilder
-
contentType(String): AmqpMessageBuilder
-
contentEncoding(String): AmqpMessageBuilder
-
expiryTime(long): AmqpMessageBuilder
-
creationTime(long): AmqpMessageBuilder
-
groupId(String): AmqpMessageBuilder
-
replyToGroupId(String): AmqpMessageBuilder
-
applicationProperties(JsonObject): AmqpMessageBuilder
-
withBooleanAsBody(boolean): AmqpMessageBuilder
-
withByteAsBody(byte): AmqpMessageBuilder
-
withShortAsBody(short): AmqpMessageBuilder
-
withIntegerAsBody(int): AmqpMessageBuilder
-
withLongAsBody(long): AmqpMessageBuilder
-
withFloatAsBody(float): AmqpMessageBuilder
-
withDoubleAsBody(double): AmqpMessageBuilder
-
withCharAsBody(char): AmqpMessageBuilder
-
withInstantAsBody(Instant): AmqpMessageBuilder
-
withUuidAsBody(UUID): AmqpMessageBuilder
-
withListAsBody(List): AmqpMessageBuilder
-
withMapAsBody(Map): AmqpMessageBuilder
-
withBufferAsBody(Buffer): AmqpMessageBuilder
-
withJsonObjectAsBody(JsonObject): AmqpMessageBuilder
-
withJsonArrayAsBody(JsonArray): AmqpMessageBuilder
-
-
AmqpReceiver
-
AmqpReceiverOptions
-
dynamic: boolean
-
qos: String
-
linkName: String
-
capabilities: List<String>
-
durable: boolean
-
maxBufferedMessages: int
-
autoAcknowledgement: boolean
-
AmqpReceiverOptions(): void
-
AmqpReceiverOptions(AmqpReceiverOptions): void
-
AmqpReceiverOptions(JsonObject): void
-
toJson(): JsonObject
-
getLinkName(): String
-
setLinkName(String): AmqpReceiverOptions
-
isDynamic(): boolean
-
setDynamic(boolean): AmqpReceiverOptions
-
getQos(): String
-
setQos(String): AmqpReceiverOptions
-
getCapabilities(): List<String>
-
setCapabilities(List<String>): AmqpReceiverOptions
-
addCapability(String): AmqpReceiverOptions
-
isDurable(): boolean
-
setDurable(boolean): AmqpReceiverOptions
-
getMaxBufferedMessages(): int
-
setMaxBufferedMessages(int): AmqpReceiverOptions
-
isAutoAcknowledgement(): boolean
-
setAutoAcknowledgement(boolean): AmqpReceiverOptions
-
-
AmqpReceiverOptionsConverter
-
AmqpSender
-
write(AmqpMessage): AmqpSender
-
write(AmqpMessage, Handler<AsyncResult<Void>>): AmqpSender
-
exceptionHandler(Handler<Throwable>): AmqpSender
-
setWriteQueueMaxSize(int): AmqpSender
-
send(AmqpMessage): AmqpSender
-
sendWithAck(AmqpMessage, Handler<AsyncResult<Void>>): AmqpSender
-
close(Handler<AsyncResult<Void>>): void
-
address(): String
-
connection(): AmqpConnection
-
-
AmqpSenderOptions
-
linkName: String
-
dynamic: boolean
-
autoDrained: boolean
-
AmqpSenderOptions(): void
-
AmqpSenderOptions(AmqpSenderOptions): void
-
AmqpSenderOptions(JsonObject): void
-
toJson(): JsonObject
-
getLinkName(): String
-
setLinkName(String): AmqpSenderOptions
-
isDynamic(): boolean
-
setDynamic(boolean): AmqpSenderOptions
-
isAutoDrained(): boolean
-
setAutoDrained(boolean): AmqpSenderOptions
-
-
AmqpSenderOptionsConverter
-
impl
-
AmqpClientImpl
-
vertx: Vertx
-
proton: ProtonClient
-
options: AmqpClientOptions
-
connections: List<AmqpConnection>
-
mustCloseVertxOnClose: boolean
-
AmqpClientImpl(Vertx, AmqpClientOptions, boolean): void
-
connect(Handler<AsyncResult<AmqpConnection>>): AmqpClient
-
close(Handler<AsyncResult<Void>>): void
-
createReceiver(String, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
-
createReceiver(String, Handler<AmqpMessage>, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
-
createReceiver(String, AmqpReceiverOptions, Handler<AmqpMessage>, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
-
createSender(String, Handler<AsyncResult<AmqpSender>>): AmqpClient
-
createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>): AmqpClient
-
register(AmqpConnectionImpl): void
-
-
AmqpConnectionImpl
-
PRODUCT: String
-
PRODUCT_KEY: Symbol
-
options: AmqpClientOptions
-
closed: AtomicBoolean
-
connection: AtomicReference<ProtonConnection>
-
context: Context
-
senders: List<AmqpSender>
-
receivers: List<AmqpReceiver>
-
exceptionHandler: Handler<Throwable>
-
AmqpConnectionImpl(Context, AmqpClientImpl, AmqpClientOptions, ProtonClient, Handler<AsyncResult<AmqpConnection>>): void
-
connect(AmqpClientImpl, ProtonClient, Handler<AsyncResult<AmqpConnection>>): void
-
onDisconnect(): void
-
getErrorMessage(ProtonConnection): String
-
runOnContext(Handler<Void>): void
-
runWithTrampoline(Handler<Void>): void
-
isLocalOpen(): boolean
-
isRemoteOpen(): boolean
-
exceptionHandler(Handler<Throwable>): AmqpConnection
-
close(Handler<AsyncResult<Void>>): AmqpConnection
-
unregister(AmqpSender): void
-
unregister(AmqpReceiver): void
-
createReceiver(String, Handler<AmqpMessage>, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
createReceiver(String, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
createReceiver(String, AmqpReceiverOptions, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
createReceiver(String, AmqpReceiverOptions, Handler<AmqpMessage>, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
-
configureTheSource(AmqpReceiverOptions, ProtonReceiver): void
-
createSender(String, Handler<AsyncResult<AmqpSender>>): AmqpConnection
-
createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>): AmqpConnection
-
createAnonymousSender(Handler<AsyncResult<AmqpSender>>): AmqpConnection
-
unwrap(): ProtonConnection
-
options(): AmqpClientOptions
-
register(AmqpSenderImpl): void
-
register(AmqpReceiverImpl): void
-
-
AmqpMessageBuilderImpl
-
message: Message
-
AmqpMessageBuilderImpl(): void
-
AmqpMessageBuilderImpl(AmqpMessage): void
-
AmqpMessageBuilderImpl(Message): void
-
build(): AmqpMessage
-
priority(short): AmqpMessageBuilderImpl
-
durable(boolean): AmqpMessageBuilder
-
id(String): AmqpMessageBuilderImpl
-
address(String): AmqpMessageBuilderImpl
-
replyTo(String): AmqpMessageBuilderImpl
-
correlationId(String): AmqpMessageBuilderImpl
-
withBody(String): AmqpMessageBuilderImpl
-
withSymbolAsBody(String): AmqpMessageBuilderImpl
-
subject(String): AmqpMessageBuilderImpl
-
contentType(String): AmqpMessageBuilderImpl
-
contentEncoding(String): AmqpMessageBuilderImpl
-
expiryTime(long): AmqpMessageBuilderImpl
-
creationTime(long): AmqpMessageBuilderImpl
-
ttl(long): AmqpMessageBuilderImpl
-
firstAcquirer(boolean): AmqpMessageBuilder
-
deliveryCount(int): AmqpMessageBuilder
-
groupId(String): AmqpMessageBuilderImpl
-
replyToGroupId(String): AmqpMessageBuilderImpl
-
applicationProperties(JsonObject): AmqpMessageBuilderImpl
-
withBooleanAsBody(boolean): AmqpMessageBuilderImpl
-
withByteAsBody(byte): AmqpMessageBuilderImpl
-
withShortAsBody(short): AmqpMessageBuilderImpl
-
withIntegerAsBody(int): AmqpMessageBuilderImpl
-
withLongAsBody(long): AmqpMessageBuilderImpl
-
withFloatAsBody(float): AmqpMessageBuilderImpl
-
withDoubleAsBody(double): AmqpMessageBuilderImpl
-
withCharAsBody(char): AmqpMessageBuilderImpl
-
withInstantAsBody(Instant): AmqpMessageBuilderImpl
-
withUuidAsBody(UUID): AmqpMessageBuilderImpl
-
withListAsBody(List): AmqpMessageBuilderImpl
-
withMapAsBody(Map): AmqpMessageBuilderImpl
-
withBufferAsBody(Buffer): AmqpMessageBuilderImpl
-
withJsonObjectAsBody(JsonObject): AmqpMessageBuilderImpl
-
withJsonArrayAsBody(JsonArray): AmqpMessageBuilderImpl
-
-
AmqpMessageImpl
-
bodyAsFloat(): float
-
message: Message
-
delivery: ProtonDelivery
-
AmqpMessageImpl(Message, ProtonDelivery): void
-
AmqpMessageImpl(Message): void
-
isDurable(): boolean
-
isFirstAcquirer(): boolean
-
priority(): int
-
id(): String
-
address(): String
-
replyTo(): String
-
correlationId(): String
-
isBodyNull(): boolean
-
getAmqpValue(): Object
-
bodyAsBoolean(): boolean
-
bodyAsByte(): byte
-
bodyAsShort(): short
-
bodyAsInteger(): int
-
bodyAsLong(): long
-
bodyAsDouble(): double
-
bodyAsChar(): char
-
bodyAsTimestamp(): Instant
-
bodyAsUUID(): UUID
-
bodyAsBinary(): Buffer
-
bodyAsString(): String
-
bodyAsSymbol(): String
-
bodyAsList(): List<Object>
-
bodyAsMap(): Map<Object, Object>
-
bodyAsJsonObject(): JsonObject
-
bodyAsJsonArray(): JsonArray
-
subject(): String
-
contentType(): String
-
contentEncoding(): String
-
expiryTime(): long
-
creationTime(): long
-
ttl(): long
-
deliveryCount(): int
-
groupId(): String
-
replyToGroupId(): String
-
groupSequence(): long
-
applicationProperties(): JsonObject
-
unwrap(): Message
-
accepted(): AmqpMessage
-
rejected(): AmqpMessage
-
released(): AmqpMessage
-
modified(boolean, boolean): AmqpMessage
-
-
AmqpReceiverImpl
-
scheduleBufferedMessageDelivery(): void
-
LOGGER: Logger
-
receiver: ProtonReceiver
-
connection: AmqpConnectionImpl
-
buffered: Queue<AmqpMessageImpl>
-
durable: boolean
-
autoAck: boolean
-
address: String
-
handler: Handler<AmqpMessage>
-
demand: long
-
closed: boolean
-
endHandler: Handler<Void>
-
exceptionHandler: Handler<Throwable>
-
initialCreditGiven: boolean
-
initialCredit: int
-
AmqpReceiverImpl(String, AmqpConnectionImpl, AmqpReceiverOptions, ProtonReceiver, Handler<AmqpMessage>, Handler<AsyncResult<AmqpReceiver>>): void
-
onClose(String, ProtonReceiver, AsyncResult<ProtonReceiver>, boolean): void
-
handleMessage(AmqpMessageImpl): void
-
exceptionHandler(Handler<Throwable>): AmqpReceiver
-
handler(Handler<AmqpMessage>): AmqpReceiver
-
pause(): AmqpReceiverImpl
-
fetch(long): AmqpReceiverImpl
-
resume(): AmqpReceiverImpl
-
endHandler(Handler<Void>): AmqpReceiverImpl
-
deliverMessageToHandler(AmqpMessageImpl): void
-
address(): String
-
connection(): AmqpConnection
-
close(Handler<AsyncResult<Void>>): void
-
isDurable(): boolean
-
-
AmqpSenderImpl
-
closed: boolean
-
connection: AmqpConnectionImpl
-
LOGGER: Logger
-
sender: ProtonSender
-
exceptionHandler: Handler<Throwable>
-
drainHandler: Handler<Void>
-
remoteCredit: long
-
AmqpSenderImpl(ProtonSender, AmqpConnectionImpl, Handler<AsyncResult<AmqpSender>>): void
-
create(ProtonSender, AmqpConnectionImpl, Handler<AsyncResult<AmqpSender>>): void
-
onClose(ProtonSender, AsyncResult<ProtonSender>, boolean): void
-
writeQueueFull(): boolean
-
connection(): AmqpConnection
-
send(AmqpMessage): AmqpSender
-
doSend(AmqpMessage, Handler<AsyncResult<Void>>): AmqpSender
-
exceptionHandler(Handler<Throwable>): AmqpSender
-
write(AmqpMessage): AmqpSender
-
write(AmqpMessage, Handler<AsyncResult<Void>>): AmqpSender
-
setWriteQueueMaxSize(int): AmqpSender
-
end(): void
-
end(Handler<AsyncResult<Void>>): void
-
drainHandler(Handler<Void>): AmqpSender
-
sendWithAck(AmqpMessage, Handler<AsyncResult<Void>>): AmqpSender
-
close(Handler<AsyncResult<Void>>): void
-
address(): String
-
-
-
-
amqp
-
vertx