Dependencies
- ant/ant/1.5.1 (available as org.apache.ant/ant/1.10.7)
- antlr/antlr/2.7.2
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- bsf/bsf/2.4.0 (available as org.apache.bsf/bsf-api/3.1)
- cglib/cglib-nodep/2.2 (available as cglib/cglib/3.3.0)
- ch.qos.logback/logback-classic/1.2.3
- ch.qos.logback/logback-core/1.2.3
- com.beust/jcommander/1.47
- com.conversantmedia/disruptor/1.2.15
- com.fasterxml/classmate/1.5.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.fasterxml.jackson.dataformat/jackson-dataformat-xml/2.10.2
- com.fasterxml.jackson.dataformat/jackson-dataformat-yaml/2.10.2
- com.fasterxml.jackson.datatype/jackson-datatype-jdk8/2.10.0
- com.fasterxml.jackson.module/jackson-module-jaxb-annotations/2.10.2
- com.fasterxml.woodstox/woodstox-core/5.0.3
- com.github.ben-manes.caffeine/caffeine/2.8.1
- com.github.jnr/jffi/1.2.15
- com.github.jnr/jffi/1.2.15/native
- com.github.jnr/jnr-constants/0.9.8
- com.github.jnr/jnr-enxio/0.16
- com.github.jnr/jnr-ffi/2.1.4
- com.github.jnr/jnr-posix/3.0.35
- com.github.jnr/jnr-unixsocket/0.18
- com.github.jnr/jnr-x86asm/1.0.2
- com.github.jponge/lzma-java/1.3
- com.github.luben/zstd-jni/1.3.8-3
- com.google.code.findbugs/jsr305/3.0.2
- com.google.errorprone/error_prone_annotations/2.3.4
- com.google.guava/failureaccess/1.0.1
- com.google.guava/guava/28.2-jre
- com.google.guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava
- com.google.j2objc/j2objc-annotations/1.3
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.hazelcast/hazelcast/3.12.6
- com.ibm.icu/icu4j/58.2
- com.jcraft/jsch/0.1.50
- com.jcraft/jsch.agentproxy.connector-factory/0.0.6
- com.jcraft/jsch.agentproxy.core/0.0.6
- com.jcraft/jsch.agentproxy.jsch/0.0.6
- com.jcraft/jsch.agentproxy.pageant/0.0.6
- com.jcraft/jsch.agentproxy.sshagent/0.0.6
- com.jcraft/jsch.agentproxy.usocket-jna/0.0.6
- com.jcraft/jsch.agentproxy.usocket-nc/0.0.6
- com.jcraft/jzlib/1.1.3
- com.lmax/disruptor/3.4.2
- commons-beanutils/commons-beanutils/1.8.3
- commons-codec/commons-codec/1.11
- commons-collections/commons-collections/3.2.1
- commons-configuration/commons-configuration/1.8
- commons-digester/commons-digester/1.8.1
- commons-httpclient/commons-httpclient/3.0
- commons-jxpath/commons-jxpath/1.3
- commons-lang/commons-lang/2.6
- commons-logging/commons-logging/1.2
- commons-net/commons-net/2.2
- commons-vfs/commons-vfs/1.0
- com.netflix.archaius/archaius-core/0.4.1
- com.netflix.hystrix/hystrix-core/1.5.12
- com.ning/compress-lzf/1.0.3
- com.rabbitmq/amqp-client/5.9.0
- com.squareup.okhttp3/okhttp/4.4.1
- com.squareup.okio/okio/2.4.3
- com.sun.istack/istack-commons-runtime/3.0.7
- com.sun.mail/javax.mail/1.6.2 (available as javax.mail/javax.mail-api/1.6.2)
- com.sun/tools/1.8
- com.sun.xml.fastinfoset/FastInfoset/1.2.15
- com.thoughtworks.qdox/qdox/1.12.1
- com.thoughtworks.xstream/xstream/1.4.7
- dom4j/dom4j/1.6.1
- io.dropwizard.metrics/metrics-core/4.1.5
- io.micrometer/micrometer-core/1.4.1
- 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.45.Final/linux-x86_64
- 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.netty/reactor-netty/0.9.5.RELEASE
- io.projectreactor/reactor-core/3.3.3.RELEASE
- io.projectreactor.tools/blockhound/1.0.3.RELEASE
- io.reactivex/rxjava/1.2.0 (available as io.reactivex.rxjava2/rxjava/2.2.11)
- io.vertx/vertx-codegen/4.0.0
- io.vertx/vertx-core/4.0.0
- io.vertx/vertx-docgen/0.9.2
- jakarta.activation/jakarta.activation-api/1.2.1
- jakarta.xml.bind/jakarta.xml.bind-api/2.3.2
- java/11
- javax.activation/activation/1.1
- javax.activation/javax.activation-api/1.2.0
- javax.cache/cache-api/1.1.1
- javax.json/javax.json-api/1.0
- javax.mail/mail/1.4
- javax.persistence/javax.persistence-api/2.2
- javax.servlet/javax.servlet-api/3.1.0
- javax.servlet/servlet-api/2.5 (available as javax.servlet/javax.servlet-api/4.0.1)
- javax.xml.bind/jaxb-api/2.3.1
- jaxen/jaxen/1.1-beta-6
- jaxme/jaxme-api/0.3
- jdk/srczip/999
- jdom/jdom/1.0
- jline/jline/2.12
- joda-time/joda-time/1.6
- junit/junit/4.12
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- msv/relaxngDatatype/20030807
- msv/xsdlib/20030807
- net.bytebuddy/byte-buddy/1.10.2 (available as net.bytebuddy/byte-buddy-dep/1.9.12)
- net.java.dev.jna/jna/4.5.2
- net.java.dev.jna/platform/3.4.0
- net.jpountz.lz4/lz4/1.3.0
- net.sf.ehcache/ehcache/2.10.6
- net.sf.kxml/kxml2/2.3.0
- net.sf.kxml/kxml2-min/2.3.0
- org.abego.treelayout/org.abego.treelayout.core/1.0.3
- org.antlr/antlr4/4.7.1
- org.antlr/antlr4-runtime/4.7.1
- org.antlr/antlr-runtime/3.5.2
- org.antlr/ST4/4.0.8
- org.antlr/stringtemplate/3.2.1
- org.apache.ant/ant/1.9.4
- org.apache.ant/ant-antlr/1.9.4
- org.apache.ant/ant-junit/1.9.4
- org.apache.ant/ant-launcher/1.9.4
- org.apache.ant/ant-nodeps/1.7.1
- org.apache.ant/ant-trax/1.7.1
- org.apache.commons/commons-compress/1.19
- org.apache.commons/commons-csv/1.7
- org.apache.commons/commons-jexl/2.1.1
- org.apache.commons/commons-vfs2/2.0
- org.apache.felix/org.osgi.compendium/1.4.0
- org.apache.felix/org.osgi.core/1.4.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.httpcomponents/httpasyncclient/4.1.4
- org.apache.httpcomponents/httpclient/4.5.12
- org.apache.httpcomponents/httpcore/4.4.13
- org.apache.httpcomponents/httpcore-nio/4.4.10
- org.apache.ivy/ivy/2.4.0
- org.apache.jackrabbit/jackrabbit-jcr-commons/1.5.2
- org.apache.jackrabbit/jackrabbit-webdav/1.5.2
- org.apache.kafka/connect-api/2.4.1
- org.apache.kafka/connect-json/2.4.1
- org.apache.kafka/kafka-clients/2.4.1
- org.apache.kafka/kafka-streams/2.4.1
- org.apache.logging.log4j/log4j-api/2.6.2
- org.apache.logging.log4j/log4j-core/2.13.1
- org.apache.maven.scm/maven-scm-api/1.4
- org.apache.maven.scm/maven-scm-provider-svn-commons/1.4
- org.apache.maven.scm/maven-scm-provider-svnexe/1.4
- org.apache.tomcat.embed/tomcat-embed-core/8.5.53
- org.apache.tomcat/tomcat-annotations-api/8.5.53
- org.apiguardian/apiguardian-api/1.0.0
- org.aspectj/aspectjweaver/1.8.14
- org.bouncycastle/bcpg-jdk14/1.45
- org.bouncycastle/bcpkix-jdk15on/1.65
- org.bouncycastle/bcprov-jdk14/1.45
- org.bouncycastle/bcprov-jdk15on/1.65
- org.brotli/dec/0.1.2
- org.checkerframework/checker-qual/2.10.0
- org.codehaus.gpars/gpars/1.2.1
- org.codehaus.groovy/groovy-all/2.4.0
- org.codehaus.janino/commons-compiler/3.0.6
- org.codehaus.janino/janino/3.0.6
- org.codehaus.jcsp/jcsp/1.1-rc5
- org.codehaus.jettison/jettison/1.2
- org.codehaus.jsr166-mirror/jsr166y/1.7.0
- org.codehaus.plexus/plexus-utils/1.5.6
- org.codehaus.woodstox/stax2-api/4.2
- org.codehaus.woodstox/wstx-asl/3.2.7
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.dom4j/dom4j/2.1.1
- org.eclipse.jetty/jetty-http/9.4.27.v20200227
- org.eclipse.jetty/jetty-io/9.4.27.v20200227
- org.eclipse.jetty/jetty-jmx/9.4.27.v20200227
- org.eclipse.jetty/jetty-server/9.4.27.v20200227
- org.eclipse.jetty/jetty-util/9.4.27.v20200227
- org.fusesource.jansi/jansi/1.17.1
- org.glassfish/javax.json/1.0.4
- org.glassfish.jaxb/jaxb-runtime/2.3.1
- org.glassfish.jaxb/txw2/2.3.1
- org.hamcrest/hamcrest-core/1.3
- org.hdrhistogram/HdrHistogram/2.1.12
- org.hibernate.common/hibernate-commons-annotations/5.1.0.Final
- org.hibernate.orm/hibernate-core/6.0.0.Alpha4
- org.hibernate.orm/hibernate-entitymanager/6.0.0.Alpha4
- org.javassist/javassist/3.24.0-GA
- org.jboss/jandex/2.1.1.Final
- org.jboss.logging/jboss-logging/3.3.2.Final
- org.jboss.logging/jboss-logging-spi/2.1.2.GA
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.jboss.netty/netty/3.2.9.Final
- org.jboss.spec.javax.transaction/jboss-transaction-api_1.2_spec/1.1.1.Final
- org.jctools/jctools-core/1.2.1
- org.jdom/jdom/1.1.3
- org.jdom/jdom2/2.0.5
- org.jetbrains/annotations/13.0
- org.jetbrains.kotlin/kotlin-stdlib/1.3.31
- org.jetbrains.kotlin/kotlin-stdlib-common/1.3.31
- org.jooq/jooq/3.13.1
- org.json/json/20080701
- org.junit.jupiter/junit-jupiter-api/5.3.1
- org.junit.jupiter/junit-jupiter-engine/5.3.1
- org.junit.platform/junit-platform-commons/1.3.1
- org.junit.platform/junit-platform-engine/1.3.1
- org.junit.vintage/junit-vintage-engine/5.3.1
- org.jvnet.staxex/stax-ex/1.8
- org.latencyutils/LatencyUtils/2.0.3
- org.lz4/lz4-java/1.6.0
- org.mongodb/bson/4.2.2
- org.mongodb/mongodb-crypt/1.0.1
- org.mongodb/mongo-java-driver/3.12.2
- org.multiverse/multiverse-core/0.7.0
- org.opentest4j/opentest4j/1.1.1
- org.ow2.asm/asm/5.0.3
- org.ow2.asm/asm-analysis/5.0.3
- org.ow2.asm/asm-commons/5.0.3
- org.ow2.asm/asm-tree/5.0.3
- org.ow2.asm/asm-util/5.0.3
- org.reactivestreams/reactive-streams/1.0.3
- org.rocksdb/rocksdbjni/5.18.3
- org.slf4j/slf4j-api/1.7.21
- org.testng/testng/6.8.13
- org.tukaani/xz/1.8
- org.xerial.snappy/snappy-java/1.1.4
- org.yaml/snakeyaml/1.24
- org.zeromq/jeromq/0.4.3
- org.zeromq/jnacl/0.1.0
- oro/oro/2.0.8
- pull-parser/pull-parser/2
- regexp/regexp/1.3
- saxpath/saxpath/1.0-FCS
- stax/stax/1.2.0
- stax/stax-api/1.0.1
- xalan/serializer/2.7.1
- xalan/xalan/2.7.1
- xerces/xercesImpl/2.10.0
- xerces/xmlParserAPIs/2.6.2
- xml-apis/xml-apis/1.3.04
- xmlpull/xmlpull/1.1.3.1
- xml-resolver/xml-resolver/1.2
- xom/xom/1.1
- xpp3/xpp3/1.1.3.3
Declarations
-
examples
-
RabbitMQExamples
-
createClientWithUri(Vertx): void
-
createClientWithManualParams(Vertx): void
-
exchangeDeclareWithConfig(RabbitMQClient): void
-
createClientWithMultipleHost(Vertx): void
-
basicPublish(RabbitMQClient): void
-
basicPublishWithConfirm(RabbitMQClient): void
-
basicConsumer(Vertx, RabbitMQClient): void
-
basicConsumerOptions(Vertx, RabbitMQClient): void
-
pauseAndResumeConsumer(RabbitMQConsumer): void
-
endHandlerConsumer(RabbitMQConsumer): void
-
cancelConsumer(RabbitMQConsumer): void
-
exceptionHandler(RabbitMQConsumer): void
-
consumerTag(RabbitMQConsumer): void
-
getMessage(RabbitMQClient): void
-
consumeWithManualAck(Vertx, RabbitMQClient): void
-
queueDeclareWithConfig(RabbitMQClient): void
-
connectionEstablishedCallback(Vertx, RabbitMQOptions): void
-
connectionEstablishedCallbackForServerNamedAutoDeleteQueue(Vertx, RabbitMQOptions): void
-
rabbitMqPublisher(Vertx, RabbitMQClient, RabbitMQPublisherOptions, Map<String, JsonObject>): void
-
-
-
io
-
vertx
-
rabbitmq
-
QueueOptions
-
DEFAULT_QUEUE_SIZE: int
-
DEFAULT_AUTO_ACK: boolean
-
DEFAULT_KEEP_MOST_RECENT: boolean
-
autoAck: boolean
-
keepMostRecent: boolean
-
maxInternalQueueSize: int
-
QueueOptions(): void
-
QueueOptions(JsonObject): void
-
setAutoAck(boolean): QueueOptions
-
setKeepMostRecent(boolean): QueueOptions
-
setMaxInternalQueueSize(int): QueueOptions
-
isAutoAck(): boolean
-
maxInternalQueueSize(): int
-
isKeepMostRecent(): boolean
-
-
QueueOptionsConverter
-
RabbitMQClient
-
create(Vertx): RabbitMQClient
-
create(Vertx, RabbitMQOptions): RabbitMQClient
-
addConnectionEstablishedCallback(Handler<Promise<Void>>): void
-
create(Vertx, JsonObject): RabbitMQClient
-
basicAck(long, boolean, Handler<AsyncResult<Void>>): void
-
basicAck(long, boolean): Future<Void>
-
basicNack(long, boolean, boolean, Handler<AsyncResult<Void>>): void
-
basicNack(long, boolean, boolean): Future<Void>
-
basicGet(String, boolean, Handler<AsyncResult<RabbitMQMessage>>): void
-
basicGet(String, boolean): Future<RabbitMQMessage>
-
basicConsumer(String, Handler<AsyncResult<RabbitMQConsumer>>): void
-
basicConsumer(String): Future<RabbitMQConsumer>
-
basicConsumer(String, QueueOptions, Handler<AsyncResult<RabbitMQConsumer>>): void
-
basicConsumer(String, QueueOptions): Future<RabbitMQConsumer>
-
basicPublish(String, String, Buffer, Handler<AsyncResult<Void>>): void
-
basicPublish(String, String, Buffer): Future<Void>
-
basicPublish(String, String, BasicProperties, Buffer, Handler<AsyncResult<Void>>): void
-
basicPublish(String, String, BasicProperties, Buffer): Future<Void>
-
basicPublishWithDeliveryTag(String, String, BasicProperties, Buffer, Handler<Long>, Handler<AsyncResult<Void>>): void
-
basicPublishWithDeliveryTag(String, String, BasicProperties, Buffer, Handler<Long>): Future<Void>
-
addConfirmListener(int, Handler<AsyncResult<ReadStream<RabbitMQConfirmation>>>): void
-
addConfirmListener(int): Future<ReadStream<RabbitMQConfirmation>>
-
confirmSelect(Handler<AsyncResult<Void>>): void
-
confirmSelect(): Future<Void>
-
waitForConfirms(Handler<AsyncResult<Void>>): void
-
waitForConfirms(): Future<Void>
-
waitForConfirms(long, Handler<AsyncResult<Void>>): void
-
waitForConfirms(long): Future<Void>
-
basicQos(int, Handler<AsyncResult<Void>>): void
-
basicQos(int): Future<Void>
-
basicQos(int, boolean, Handler<AsyncResult<Void>>): void
-
basicQos(int, boolean): Future<Void>
-
basicQos(int, int, boolean, Handler<AsyncResult<Void>>): void
-
basicQos(int, int, boolean): Future<Void>
-
exchangeDeclare(String, String, boolean, boolean, Handler<AsyncResult<Void>>): void
-
exchangeDeclare(String, String, boolean, boolean): Future<Void>
-
exchangeDeclare(String, String, boolean, boolean, JsonObject, Handler<AsyncResult<Void>>): void
-
exchangeDeclare(String, String, boolean, boolean, JsonObject): Future<Void>
-
exchangeDelete(String, Handler<AsyncResult<Void>>): void
-
exchangeDelete(String): Future<Void>
-
exchangeBind(String, String, String, Handler<AsyncResult<Void>>): void
-
exchangeBind(String, String, String): Future<Void>
-
exchangeBind(String, String, String, Map<String, Object>, Handler<AsyncResult<Void>>): void
-
exchangeBind(String, String, String, Map<String, Object>): Future<Void>
-
exchangeUnbind(String, String, String, Handler<AsyncResult<Void>>): void
-
exchangeUnbind(String, String, String): Future<Void>
-
exchangeUnbind(String, String, String, Map<String, Object>, Handler<AsyncResult<Void>>): void
-
exchangeUnbind(String, String, String, Map<String, Object>): Future<Void>
-
queueDeclareAuto(Handler<AsyncResult<JsonObject>>): void
-
queueDeclareAuto(): Future<JsonObject>
-
queueDeclare(String, boolean, boolean, boolean, Handler<AsyncResult<DeclareOk>>): void
-
queueDeclare(String, boolean, boolean, boolean): Future<DeclareOk>
-
queueDeclare(String, boolean, boolean, boolean, JsonObject, Handler<AsyncResult<DeclareOk>>): void
-
queueDeclare(String, boolean, boolean, boolean, JsonObject): Future<DeclareOk>
-
queueDelete(String, Handler<AsyncResult<DeleteOk>>): void
-
queueDelete(String): Future<DeleteOk>
-
queueDeleteIf(String, boolean, boolean, Handler<AsyncResult<DeleteOk>>): void
-
queueDeleteIf(String, boolean, boolean): Future<DeleteOk>
-
queueBind(String, String, String, Handler<AsyncResult<Void>>): void
-
queueBind(String, String, String): Future<Void>
-
queueBind(String, String, String, Map<String, Object>, Handler<AsyncResult<Void>>): void
-
queueBind(String, String, String, Map<String, Object>): Future<Void>
-
queueUnbind(String, String, String, Handler<AsyncResult<Void>>): void
-
queueUnbind(String, String, String): Future<Void>
-
queueUnbind(String, String, String, Map<String, Object>, Handler<AsyncResult<Void>>): void
-
queueUnbind(String, String, String, Map<String, Object>): Future<Void>
-
messageCount(String, Handler<AsyncResult<Long>>): void
-
messageCount(String): Future<Long>
-
start(Handler<AsyncResult<Void>>): void
-
start(): Future<Void>
-
stop(Handler<AsyncResult<Void>>): void
-
stop(): Future<Void>
-
isConnected(): boolean
-
isOpenChannel(): boolean
-
-
RabbitMQConfirmation
-
RabbitMQConfirmationConverter
-
RabbitMQConsumer
-
exceptionHandler(Handler<Throwable>): RabbitMQConsumer
-
handler(Handler<RabbitMQMessage>): RabbitMQConsumer
-
pause(): RabbitMQConsumer
-
resume(): RabbitMQConsumer
-
endHandler(Handler<Void>): RabbitMQConsumer
-
queueName(): String
-
setQueueName(String): RabbitMQConsumer
-
consumerTag(): String
-
cancel(): Future<Void>
-
cancel(Handler<AsyncResult<Void>>): void
-
isCancelled(): boolean
-
isPaused(): boolean
-
fetch(long): RabbitMQConsumer
-
-
RabbitMQMessage
-
RabbitMQOptions
-
DEFAULT_PASSWORD: String
-
DEFAULT_PORT: int
-
DEFAULT_HOST: String
-
DEFAULT_USER: String
-
DEFAULT_VIRTUAL_HOST: String
-
DEFAULT_CONNECTION_TIMEOUT: int
-
DEFAULT_REQUESTED_HEARTBEAT: int
-
DEFAULT_HANDSHAKE_TIMEOUT: int
-
DEFAULT_REQUESTED_CHANNEL_MAX: int
-
DEFAULT_NETWORK_RECOVERY_INTERNAL: long
-
DEFAULT_AUTOMATIC_RECOVERY_ENABLED: boolean
-
DEFAULT_RECONNECT_INTERVAL: long
-
uri: String
-
addresses: List<Address>
-
user: String
-
password: String
-
host: String
-
virtualHost: String
-
port: int
-
connectionTimeout: int
-
requestedHeartbeat: int
-
handshakeTimeout: int
-
requestedChannelMax: int
-
networkRecoveryInterval: long
-
automaticRecoveryEnabled: boolean
-
includeProperties: boolean
-
RabbitMQOptions(): void
-
RabbitMQOptions(JsonObject): void
-
RabbitMQOptions(RabbitMQOptions): void
-
init(): void
-
getAddresses(): List<Address>
-
setAddresses(List<Address>): RabbitMQOptions
-
getUri(): String
-
setUri(String): RabbitMQOptions
-
getUser(): String
-
setUser(String): RabbitMQOptions
-
getPassword(): String
-
setPassword(String): RabbitMQOptions
-
getHost(): String
-
setHost(String): RabbitMQOptions
-
getVirtualHost(): String
-
setVirtualHost(String): RabbitMQOptions
-
getPort(): int
-
setPort(int): RabbitMQOptions
-
getConnectionTimeout(): int
-
setConnectionTimeout(int): RabbitMQOptions
-
getRequestedHeartbeat(): int
-
setRequestedHeartbeat(int): RabbitMQOptions
-
getHandshakeTimeout(): int
-
setHandshakeTimeout(int): RabbitMQOptions
-
getRequestedChannelMax(): int
-
setRequestedChannelMax(int): RabbitMQOptions
-
getNetworkRecoveryInterval(): long
-
setNetworkRecoveryInterval(long): RabbitMQOptions
-
isAutomaticRecoveryEnabled(): boolean
-
setAutomaticRecoveryEnabled(boolean): RabbitMQOptions
-
getIncludeProperties(): boolean
-
setIncludeProperties(boolean): RabbitMQOptions
-
setReconnectAttempts(int): RabbitMQOptions
-
setReconnectInterval(long): RabbitMQOptions
-
setSsl(boolean): RabbitMQOptions
-
setTrustAll(boolean): RabbitMQOptions
-
setKeyCertOptions(KeyCertOptions): RabbitMQOptions
-
setKeyStoreOptions(JksOptions): RabbitMQOptions
-
setPfxKeyCertOptions(PfxOptions): RabbitMQOptions
-
setPemKeyCertOptions(PemKeyCertOptions): RabbitMQOptions
-
setTrustOptions(TrustOptions): RabbitMQOptions
-
setPemTrustOptions(PemTrustOptions): RabbitMQOptions
-
setPfxTrustOptions(PfxOptions): RabbitMQOptions
-
-
RabbitMQOptionsConverter
-
RabbitMQPublisher
-
create(Vertx, RabbitMQClient, RabbitMQPublisherOptions): RabbitMQPublisher
-
start(Handler<AsyncResult<Void>>): void
-
start(): Future<Void>
-
stop(Handler<AsyncResult<Void>>): void
-
stop(): Future<Void>
-
restart(): void
-
getConfirmationStream(): ReadStream<RabbitMQPublisherConfirmation>
-
publish(String, String, BasicProperties, Buffer, Handler<AsyncResult<Void>>): void
-
publish(String, String, BasicProperties, Buffer): Future<Void>
-
queueSize(): int
-
-
RabbitMQPublisherConfirmation
-
RabbitMQPublisherConfirmationConverter
-
RabbitMQPublisherOptions
-
DEFAULT_RECONNECT_INTERVAL: long
-
DEFAULT_RECONNECT_ATTEMPTS: Integer
-
DEFAULT_QUEUE_SIZE: int
-
reconnectAttempts: Integer
-
reconnectInterval: long
-
maxInternalQueueSize: int
-
RabbitMQPublisherOptions(): void
-
RabbitMQPublisherOptions(JsonObject): void
-
RabbitMQPublisherOptions(RabbitMQPublisherOptions): void
-
getReconnectAttempts(): Integer
-
setReconnectAttempts(Integer): RabbitMQPublisherOptions
-
getReconnectInterval(): long
-
setReconnectInterval(long): RabbitMQPublisherOptions
-
getMaxInternalQueueSize(): int
-
setMaxInternalQueueSize(int): RabbitMQPublisherOptions
-
-
RabbitMQPublisherOptionsConverter
-
impl
-
ChannelConfirmHandler
-
QueueConsumerHandler
-
queue: RabbitMQConsumerImpl
-
handlerContext: Context
-
shutdownHandler: Handler<ShutdownSignalException>
-
log: Logger
-
QueueConsumerHandler(Vertx, Channel, QueueOptions, String): void
-
setShutdownHandler(Handler<ShutdownSignalException>): void
-
handleDelivery(String, Envelope, BasicProperties, byte[]): void
-
handleConsumeOk(String): void
-
handleCancel(String): void
-
handleShutdownSignal(String, ShutdownSignalException): void
-
queue(): RabbitMQConsumer
-
-
RabbitMQClientImpl
-
channel: Channel
-
log: Logger
-
emptyConfig: JsonObject
-
vertx: Vertx
-
config: RabbitMQOptions
-
retries: int
-
connection: Connection
-
channelInstance: long
-
channelConfirms: boolean
-
connectionEstablishedCallbacks: List<Handler<Promise<Void>>>
-
RabbitMQClientImpl(Vertx, RabbitMQOptions): void
-
getChannelInstance(): long
-
addConnectionEstablishedCallback(Handler<Promise<Void>>): void
-
newConnection(Vertx, RabbitMQOptions): Connection
-
isConnected(): boolean
-
isOpenChannel(): boolean
-
basicAck(long, boolean, Handler<AsyncResult<Void>>): void
-
basicAck(long, boolean): Future<Void>
-
basicNack(long, boolean, boolean, Handler<AsyncResult<Void>>): void
-
basicNack(long, boolean, boolean): Future<Void>
-
restartConsumer(int, QueueConsumerHandler, QueueOptions): void
-
basicConsumer(String, QueueOptions, Handler<AsyncResult<RabbitMQConsumer>>): void
-
basicConsumer(String, QueueOptions): Future<RabbitMQConsumer>
-
basicGet(String, boolean, Handler<AsyncResult<RabbitMQMessage>>): void
-
basicGet(String, boolean): Future<RabbitMQMessage>
-
basicPublish(String, String, Buffer, Handler<AsyncResult<Void>>): void
-
basicPublish(String, String, Buffer): Future<Void>
-
basicPublish(String, String, BasicProperties, Buffer, Handler<AsyncResult<Void>>): void
-
basicPublish(String, String, BasicProperties, Buffer): Future<Void>
-
basicPublishWithDeliveryTag(String, String, BasicProperties, Buffer, Handler<Long>, Handler<AsyncResult<Void>>): void
-
basicPublishWithDeliveryTag(String, String, BasicProperties, Buffer, Handler<Long>): Future<Void>
-
addConfirmListener(int, Handler<AsyncResult<ReadStream<RabbitMQConfirmation>>>): void
-
addConfirmListener(int): Future<ReadStream<RabbitMQConfirmation>>
-
confirmSelect(Handler<AsyncResult<Void>>): void
-
confirmSelect(): Future<Void>
-
waitForConfirms(Handler<AsyncResult<Void>>): void
-
waitForConfirms(): Future<Void>
-
waitForConfirms(long, Handler<AsyncResult<Void>>): void
-
waitForConfirms(long): Future<Void>
-
basicQos(int, int, boolean, Handler<AsyncResult<Void>>): void
-
basicQos(int, int, boolean): Future<Void>
-
exchangeDeclare(String, String, boolean, boolean, Handler<AsyncResult<Void>>): void
-
exchangeDeclare(String, String, boolean, boolean): Future<Void>
-
exchangeDeclare(String, String, boolean, boolean, JsonObject, Handler<AsyncResult<Void>>): void
-
exchangeDeclare(String, String, boolean, boolean, JsonObject): Future<Void>
-
exchangeDelete(String, Handler<AsyncResult<Void>>): void
-
exchangeDelete(String): Future<Void>
-
exchangeBind(String, String, String, Handler<AsyncResult<Void>>): void
-
exchangeBind(String, String, String): Future<Void>
-
exchangeBind(String, String, String, Map<String, Object>, Handler<AsyncResult<Void>>): void
-
exchangeBind(String, String, String, Map<String, Object>): Future<Void>
-
exchangeUnbind(String, String, String, Handler<AsyncResult<Void>>): void
-
exchangeUnbind(String, String, String): Future<Void>
-
exchangeUnbind(String, String, String, Map<String, Object>, Handler<AsyncResult<Void>>): void
-
exchangeUnbind(String, String, String, Map<String, Object>): Future<Void>
-
queueDeclareAuto(Handler<AsyncResult<JsonObject>>): void
-
queueDeclareAuto(): Future<JsonObject>
-
queueDeclare(String, boolean, boolean, boolean, Handler<AsyncResult<DeclareOk>>): void
-
queueDeclare(String, boolean, boolean, boolean): Future<DeclareOk>
-
queueDeclare(String, boolean, boolean, boolean, JsonObject, Handler<AsyncResult<DeclareOk>>): void
-
queueDeclare(String, boolean, boolean, boolean, JsonObject): Future<DeclareOk>
-
queueDelete(String, Handler<AsyncResult<DeleteOk>>): void
-
queueDelete(String): Future<DeleteOk>
-
queueDeleteIf(String, boolean, boolean, Handler<AsyncResult<DeleteOk>>): void
-
queueDeleteIf(String, boolean, boolean): Future<DeleteOk>
-
queueBind(String, String, String, Handler<AsyncResult<Void>>): void
-
queueBind(String, String, String): Future<Void>
-
queueBind(String, String, String, Map<String, Object>, Handler<AsyncResult<Void>>): void
-
queueBind(String, String, String, Map<String, Object>): Future<Void>
-
queueUnbind(String, String, String, Handler<AsyncResult<Void>>): void
-
queueUnbind(String, String, String): Future<Void>
-
queueUnbind(String, String, String, Map<String, Object>, Handler<AsyncResult<Void>>): void
-
queueUnbind(String, String, String, Map<String, Object>): Future<Void>
-
messageCount(String, Handler<AsyncResult<Long>>): void
-
messageCount(String): Future<Long>
-
start(Handler<AsyncResult<Void>>): void
-
start(): Future<Void>
-
start(ContextInternal, int): Future<Void>
-
stop(Handler<AsyncResult<Void>>): void
-
stop(): Future<Void>
-
forChannel(ChannelHandler<Object>): Future<Object>
-
connect(): Future<Void>
-
connectCallbackHandler(AsyncResult<Void>, Iterator<Handler<Promise<Void>>>, Promise<Void>): void
-
disconnect(): void
-
shutdownCompleted(ShutdownSignalException): void
-
ChannelHandler
-
-
RabbitMQConfirmListenerImpl
-
client: RabbitMQClientImpl
-
pending: InboundBuffer<RabbitMQConfirmation>
-
maxQueueSize: int
-
exceptionHandler: Handler<Throwable>
-
RabbitMQConfirmListenerImpl(RabbitMQClientImpl, Context, int): void
-
handleAck(long, boolean, boolean): void
-
exceptionHandler(Handler<Throwable>): RabbitMQConfirmListenerImpl
-
handler(Handler<RabbitMQConfirmation>): RabbitMQConfirmListenerImpl
-
handleException(Throwable): void
-
pause(): RabbitMQConfirmListenerImpl
-
resume(): RabbitMQConfirmListenerImpl
-
fetch(long): RabbitMQConfirmListenerImpl
-
endHandler(Handler<Void>): RabbitMQConfirmListenerImpl
-
-
RabbitMQConsumerImpl
-
log: Logger
-
exceptionHandler: Handler<Throwable>
-
endHandler: Handler<Void>
-
queueName: String
-
consumerHandler: QueueConsumerHandler
-
keepMostRecent: boolean
-
pending: InboundBuffer<RabbitMQMessage>
-
maxQueueSize: int
-
cancelled: boolean
-
RabbitMQConsumerImpl(Context, QueueConsumerHandler, QueueOptions, String): void
-
queueName(): String
-
setQueueName(String): RabbitMQConsumer
-
exceptionHandler(Handler<Throwable>): RabbitMQConsumer
-
handler(Handler<RabbitMQMessage>): RabbitMQConsumer
-
pause(): RabbitMQConsumer
-
resume(): RabbitMQConsumer
-
fetch(long): RabbitMQConsumer
-
endHandler(Handler<Void>): RabbitMQConsumer
-
consumerTag(): String
-
cancel(): Future<Void>
-
cancel(Handler<AsyncResult<Void>>): void
-
isCancelled(): boolean
-
isPaused(): boolean
-
handleMessage(RabbitMQMessage): void
-
handleException(Throwable): void
-
handleEnd(): void
-
-
RabbitMQMessageImpl
-
RabbitMQPublisherImpl
-
log: Logger
-
vertx: Vertx
-
client: RabbitMQClient
-
confirmations: InboundBuffer<RabbitMQPublisherConfirmation>
-
context: Context
-
options: RabbitMQPublisherOptions
-
pendingAcks: Deque<MessageDetails>
-
sendQueue: InboundBuffer<MessageDetails>
-
lastChannelInstance: long
-
stopped: boolean
-
MessageDetails
-
RabbitMQPublisherImpl(Vertx, RabbitMQClient, RabbitMQPublisherOptions): void
-
start(Handler<AsyncResult<Void>>): void
-
start(): Future<Void>
-
stop(Handler<AsyncResult<Void>>): void
-
stop(): Future<Void>
-
restart(): void
-
startForPromise(): Promise<Void>
-
addConfirmListener(RabbitMQClient, RabbitMQPublisherOptions, Promise<Void>): void
-
getConfirmationStream(): ReadStream<RabbitMQPublisherConfirmation>
-
queueSize(): int
-
handleMessageSend(MessageDetails): void
-
doSend(MessageDetails): void
-
handleConfirmation(RabbitMQConfirmation): void
-
publish(String, String, BasicProperties, Buffer, Handler<AsyncResult<Void>>): void
-
publish(String, String, BasicProperties, Buffer): Future<Void>
-
exceptionHandler(Handler<Throwable>): RabbitMQPublisherImpl
-
handler(Handler<RabbitMQPublisherConfirmation>): RabbitMQPublisherImpl
-
pause(): RabbitMQPublisherImpl
-
resume(): RabbitMQPublisherImpl
-
fetch(long): RabbitMQPublisherImpl
-
endHandler(Handler<Void>): RabbitMQPublisherImpl
-
-
Utils
-
populate(JsonObject, Envelope): void
-
toJson(DeclareOk): JsonObject
-
toJson(DeleteOk): JsonObject
-
toJson(BasicProperties): JsonObject
-
convertMapLongStringToString(Map<String, Object>): Map<String, Object>
-
convertLongStringToString(Object): Object
-
fromJson(JsonObject): BasicProperties
-
parse(BasicProperties, byte[]): Object
-
decode(String, byte[]): String
-
encode(String, String): byte[]
-
put(String, Object, JsonObject): void
-
put(String, Date, JsonObject): void
-
parseDate(String): Date
-
asMap(JsonObject): Map<String, Object>
-
dateTimeFormatter: DateTimeFormatter
-
-
-
-
rabbitmq
-
vertx