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.11.3
- com.fasterxml.jackson.core/jackson-core/2.11.3
- com.fasterxml.jackson.core/jackson-databind/2.11.3
- 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.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-haproxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-tcnative/2.0.30.Final
- io.netty/netty-transport/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.projectreactor.tools/blockhound/1.0.3.RELEASE
- io.vertx/vertx-codegen/4.0.0
- io.vertx/vertx-core/4.0.0
- io.vertx/vertx-docgen/0.9.2
- io.vertx/vertx-proton/4.0.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.8
- org.bouncycastle/bcpkix-jdk15on/1.65
- org.bouncycastle/bcprov-jdk15on/1.65
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.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
-
AmqpClientExamples
-
io
-
vertx
-
amqp
-
AmqpClient
- create(AmqpClientOptions): AmqpClient
- create(Vertx, AmqpClientOptions): AmqpClient
- connect(Handler<AsyncResult<AmqpConnection>>): AmqpClient
- connect(): Future<AmqpConnection>
- close(Handler<AsyncResult<Void>>): void
- close(): Future<Void>
- createReceiver(String, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
- createReceiver(String): Future<AmqpReceiver>
- createReceiver(String, AmqpReceiverOptions, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
- createReceiver(String, AmqpReceiverOptions): Future<AmqpReceiver>
- createSender(String, Handler<AsyncResult<AmqpSender>>): AmqpClient
- createSender(String): Future<AmqpSender>
- createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>): AmqpClient
- createSender(String, AmqpSenderOptions): Future<AmqpSender>
-
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
- 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
- close(): Future<Void>
- createReceiver(String, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
- createReceiver(String): Future<AmqpReceiver>
- createReceiver(String, AmqpReceiverOptions, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
- createReceiver(String, AmqpReceiverOptions): Future<AmqpReceiver>
- createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
- createDynamicReceiver(): Future<AmqpReceiver>
- createSender(String, Handler<AsyncResult<AmqpSender>>): AmqpConnection
- createSender(String): Future<AmqpSender>
- createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>): AmqpConnection
- createSender(String, AmqpSenderOptions): Future<AmqpSender>
- createAnonymousSender(Handler<AsyncResult<AmqpSender>>): AmqpConnection
- createAnonymousSender(): Future<AmqpSender>
- isDisconnected(): boolean
-
AmqpMessage
- id(): String
- address(): String
- replyTo(): String
- create(): AmqpMessageBuilder
- create(AmqpMessage): AmqpMessageBuilder
- create(Message): AmqpMessageBuilder
- isDurable(): boolean
- isFirstAcquirer(): boolean
- priority(): int
- deliveryCount(): int
- ttl(): long
- correlationId(): String
- isBodyNull(): boolean
- 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
- rejected(): AmqpMessage
- released(): 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
- address(): String
- exceptionHandler(Handler<Throwable>): AmqpReceiver
- handler(Handler<AmqpMessage>): AmqpReceiver
- pause(): AmqpReceiver
- resume(): AmqpReceiver
- fetch(long): AmqpReceiver
- endHandler(Handler<Void>): AmqpReceiver
- close(Handler<AsyncResult<Void>>): void
- close(): Future<Void>
- connection(): AmqpConnection
-
AmqpReceiverOptions
- linkName: String
- dynamic: boolean
- qos: 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
- exceptionHandler(Handler<Throwable>): AmqpSender
- setWriteQueueMaxSize(int): AmqpSender
- send(AmqpMessage): AmqpSender
- sendWithAck(AmqpMessage, Handler<AsyncResult<Void>>): AmqpSender
- sendWithAck(AmqpMessage): Future<Void>
- close(Handler<AsyncResult<Void>>): void
- close(): Future<Void>
- address(): String
- connection(): AmqpConnection
- remainingCredits(): long
-
AmqpSenderOptions
- linkName: String
- dynamic: boolean
- autoDrained: boolean
- capabilities: List<String>
- 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
- getCapabilities(): List<String>
- setCapabilities(List<String>): AmqpSenderOptions
- addCapability(String): 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
- connect(): Future<AmqpConnection>
- close(Handler<AsyncResult<Void>>): void
- close(): Future<Void>
- createReceiver(String, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
- createReceiver(String): Future<AmqpReceiver>
- createReceiver(String, AmqpReceiverOptions, Handler<AsyncResult<AmqpReceiver>>): AmqpClient
- createReceiver(String, AmqpReceiverOptions): Future<AmqpReceiver>
- createSender(String, Handler<AsyncResult<AmqpSender>>): AmqpClient
- createSender(String): Future<AmqpSender>
- createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>): AmqpClient
- createSender(String, AmqpSenderOptions): Future<AmqpSender>
- register(AmqpConnectionImpl): void
-
AmqpConnectionImpl
- options(): AmqpClientOptions
- 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
- close(): Future<Void>
- unregister(AmqpSender): void
- unregister(AmqpReceiver): void
- createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
- createDynamicReceiver(): Future<AmqpReceiver>
- createReceiver(String, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
- createReceiver(String): Future<AmqpReceiver>
- createReceiver(String, AmqpReceiverOptions, Handler<AsyncResult<AmqpReceiver>>): AmqpConnection
- createReceiver(String, AmqpReceiverOptions): Future<AmqpReceiver>
- configureTheSource(AmqpReceiverOptions, ProtonReceiver): void
- createSender(String, Handler<AsyncResult<AmqpSender>>): AmqpConnection
- createSender(String): Future<AmqpSender>
- createSender(String, AmqpSenderOptions, Handler<AsyncResult<AmqpSender>>): AmqpConnection
- configureTheTarget(AmqpSenderOptions, ProtonSender): void
- createSender(String, AmqpSenderOptions): Future<AmqpSender>
- createAnonymousSender(Handler<AsyncResult<AmqpSender>>): AmqpConnection
- createAnonymousSender(): Future<AmqpSender>
- isDisconnected(): boolean
- unwrap(): ProtonConnection
- 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
- message: Message
- delivery: ProtonDelivery
- connection: AmqpConnectionImpl
- AmqpMessageImpl(Message, ProtonDelivery, AmqpConnectionImpl): 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
- 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
- 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
- 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<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(Handler<AmqpMessage>, AmqpMessageImpl): void
- scheduleBufferedMessageDelivery(): void
- address(): String
- connection(): AmqpConnection
- close(Handler<AsyncResult<Void>>): void
- close(): Future<Void>
- isDurable(): boolean
-
AmqpSenderImpl
- remoteCredit: long
- LOGGER: Logger
- sender: ProtonSender
- connection: AmqpConnectionImpl
- closed: boolean
- exceptionHandler: Handler<Throwable>
- drainHandler: Handler<Void>
- 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): Future<Void>
- write(AmqpMessage, Handler<AsyncResult<Void>>): void
- setWriteQueueMaxSize(int): AmqpSender
- end(Handler<AsyncResult<Void>>): void
- drainHandler(Handler<Void>): AmqpSender
- sendWithAck(AmqpMessage, Handler<AsyncResult<Void>>): AmqpSender
- sendWithAck(AmqpMessage): Future<Void>
- close(Handler<AsyncResult<Void>>): void
- close(): Future<Void>
- address(): String
- remainingCredits(): long
-
AmqpClientImpl
-
AmqpClient
-
amqp
-
vertx