Dependencies
- ant/ant/1.5.1 (available as org.apache.ant/ant/1.10.7)
- antlr/antlr/2.7.7
- asm/asm/2.2.1 (available as org.ow2.asm/asm/4.2)
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- bcel/bcel/5.1 (available as org.apache.bcel/bcel/6.4.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
- cobertura/cobertura/1.8 (available as net.sourceforge.cobertura/cobertura/2.1.1)
- com.beust/jcommander/1.47
- com.fasterxml/classmate/1.3.0
- 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.ben-manes.caffeine/caffeine/2.6.1
- com.github.jponge/lzma-java/1.3
- com.google.code.findbugs/jsr305/3.0.2
- com.google.errorprone/error_prone_annotations/2.0.18
- com.google.guava/guava/23.0
- com.google.j2objc/j2objc-annotations/1.1
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.hazelcast/hazelcast/3.8.9
- 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
- commons-beanutils/commons-beanutils/1.8.3
- commons-codec/commons-codec/1.5
- 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-jelly/commons-jelly-tags-log/1.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.4.2
- com.squareup.okhttp3/okhttp/3.9.1
- com.squareup.okio/okio/1.13.0
- com.sun/tools/1.8
- com.thoughtworks.qdox/qdox/1.12.1
- com.thoughtworks.xstream/xstream/1.4.7
- dom4j/dom4j/1.6.1
- findbugs/annotations/1.0.0
- findbugs/bcel/5.1
- findbugs/coreplugin/1.0.0
- findbugs/findbugs/1.0.0 (available as com.google.code.findbugs/annotations/3.0.1)
- findbugs/findbugs-ant/1.0.0
- findbugs/findbugsGUI/1.0.0
- io.dropwizard.metrics/metrics-core/3.2.6
- io.micrometer/micrometer-core/1.0.2
- 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.projectreactor/reactor-core/3.1.4.RELEASE
- io.reactivex/rxjava/1.2.0 (available as io.reactivex.rxjava2/rxjava/2.2.11)
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- java/11
- javax.activation/activation/1.1
- javax.cache/cache-api/1.0.0
- javax.mail/mail/1.4
- javax.servlet/javax.servlet-api/3.1.0
- javax.servlet/servlet-api/2.5 (available as javax.servlet/javax.servlet-api/4.0.1)
- jaxen/jaxen/1.1.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
- net.bytebuddy/byte-buddy/1.6.14 (available as net.bytebuddy/byte-buddy-dep/1.9.12)
- net.java.dev.jna/jna/3.4.0
- net.java.dev.jna/platform/3.4.0
- net.jpountz.lz4/lz4/1.3.0
- net.sf.ehcache/ehcache/2.10.4
- net.sf.kxml/kxml2/2.3.0
- net.sf.kxml/kxml2-min/2.3.0
- 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-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.ivy/ivy/2.4.0
- org.apache.jackrabbit/jackrabbit-jcr-commons/1.5.2
- org.apache.jackrabbit/jackrabbit-webdav/1.5.2
- org.apache.logging.log4j/log4j-api/2.6.2
- 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.28
- org.apache.tomcat/tomcat-annotations-api/8.5.28
- org.aspectj/aspectjweaver/1.8.13
- org.bouncycastle/bcpg-jdk14/1.45
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk14/1.45
- org.bouncycastle/bcprov-jdk15on/1.54
- 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.mojo/animal-sniffer-annotations/1.14
- org.codehaus.plexus/plexus-utils/1.5.6
- org.codehaus.woodstox/wstx-asl/3.2.7
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.eclipse.jetty/jetty-http/9.4.8.v20171121
- org.eclipse.jetty/jetty-io/9.4.8.v20171121
- org.eclipse.jetty/jetty-jmx/9.4.8.v20171121
- org.eclipse.jetty/jetty-server/9.4.8.v20171121
- org.eclipse.jetty/jetty-util/9.4.8.v20171121
- org.fusesource.jansi/jansi/1.9
- org.hamcrest/hamcrest-core/1.3
- org.hdrhistogram/HdrHistogram/2.1.10
- org.hibernate.common/hibernate-commons-annotations/5.0.1.Final
- org.hibernate/hibernate-core/5.2.13.Final
- org.hibernate/hibernate-entitymanager/5.2.13.Final
- org.hibernate.javax.persistence/hibernate-jpa-2.1-api/1.0.0.Final
- org.javassist/javassist/3.22.0-GA
- org.jboss/jandex/2.0.3.Final
- org.jboss.logging/jboss-logging/3.3.1.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.0.1.Final
- org.jdom/jdom/1.1.3
- org.jdom/jdom2/2.0.5
- org.jetbrains/annotations/13.0
- org.jetbrains.kotlin/kotlin-stdlib/1.1.61
- org.json/json/20080701
- org.latencyutils/LatencyUtils/2.0.3
- org.multiverse/multiverse-core/0.7.0
- org.mvel/mvel2/2.3.1.Final
- org.reactivestreams/reactive-streams/1.0.2
- org.slf4j/slf4j-api/1.7.21
- org.testng/testng/6.8.13
- org.yaml/snakeyaml/1.12
- oro/oro/2.0.8
- 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
- xml-apis/xml-apis/1.3.04
- xmlpull/xmlpull/1.1.3.1
- xml-resolver/xml-resolver/1.2
- xom/xom/1.1
Declarations
-
examples
-
RabbitMQExamples
- createClientWithUri(Vertx): void
- createClientWithManualParams(Vertx): void
- createClientWithMultipleHost(Vertx): void
- basicPublish(RabbitMQClient): void
- exchangeDeclareWithConfig(RabbitMQClient): void
- basicPublishWithConfirm(RabbitMQClient): void
- basicConsume(Vertx, 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
-
RabbitMQExamples
-
io
-
vertx
-
rabbitmq
- BasicProperties
- Envelope
-
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
- isOpenChannel(): boolean
- create(Vertx): RabbitMQClient
- create(Vertx, RabbitMQOptions): RabbitMQClient
- create(Vertx, JsonObject): RabbitMQClient
- basicAck(long, boolean, Handler<AsyncResult<JsonObject>>): void
- basicNack(long, boolean, boolean, Handler<AsyncResult<JsonObject>>): void
- basicGet(String, boolean, Handler<AsyncResult<JsonObject>>): void
- basicConsume(String, String, Handler<AsyncResult<String>>): void
- basicConsume(String, String, boolean, Handler<AsyncResult<String>>): void
- basicConsume(String, String, boolean, Handler<AsyncResult<String>>, Handler<Throwable>): void
- basicCancel(String): void
- basicCancel(String, Handler<AsyncResult<Void>>): void
- basicConsumer(String, Handler<AsyncResult<RabbitMQConsumer>>): void
- basicConsumer(String, QueueOptions, Handler<AsyncResult<RabbitMQConsumer>>): void
- basicPublish(String, String, JsonObject, Handler<AsyncResult<Void>>): void
- confirmSelect(Handler<AsyncResult<Void>>): void
- waitForConfirms(Handler<AsyncResult<Void>>): void
- stop(Handler<AsyncResult<Void>>): void
- waitForConfirms(long, Handler<AsyncResult<Void>>): void
- basicQos(int, Handler<AsyncResult<Void>>): void
- basicQos(int, boolean, Handler<AsyncResult<Void>>): void
- basicQos(int, int, boolean, Handler<AsyncResult<Void>>): void
- exchangeDeclare(String, String, boolean, boolean, Handler<AsyncResult<Void>>): void
- exchangeDeclare(String, String, boolean, boolean, Map<String, String>, Handler<AsyncResult<Void>>): void
- exchangeDeclare(String, String, boolean, boolean, JsonObject, Handler<AsyncResult<Void>>): void
- exchangeDelete(String, Handler<AsyncResult<Void>>): void
- exchangeBind(String, String, String, Handler<AsyncResult<Void>>): void
- exchangeUnbind(String, String, String, Handler<AsyncResult<Void>>): void
- queueDeclareAuto(Handler<AsyncResult<JsonObject>>): void
- queueDeclare(String, boolean, boolean, boolean, Handler<AsyncResult<JsonObject>>): void
- queueDeclare(String, boolean, boolean, boolean, Map<String, String>, Handler<AsyncResult<JsonObject>>): void
- queueDeclare(String, boolean, boolean, boolean, JsonObject, Handler<AsyncResult<JsonObject>>): void
- queueDelete(String, Handler<AsyncResult<JsonObject>>): void
- queueDeleteIf(String, boolean, boolean, Handler<AsyncResult<JsonObject>>): void
- queueBind(String, String, String, Handler<AsyncResult<Void>>): void
- messageCount(String, Handler<AsyncResult<Long>>): void
- start(Handler<AsyncResult<Void>>): void
- isConnected(): boolean
-
RabbitMQConsumer
- endHandler(Handler<Void>): RabbitMQConsumer
- exceptionHandler(Handler<Throwable>): RabbitMQConsumer
- handler(Handler<RabbitMQMessage>): RabbitMQConsumer
- pause(): RabbitMQConsumer
- resume(): RabbitMQConsumer
- consumerTag(): String
- cancel(): void
- cancel(Handler<AsyncResult<Void>>): void
- isPaused(): boolean
- RabbitMQMessage
-
RabbitMQOptions
- DEFAULT_PORT: int
- DEFAULT_HOST: String
- DEFAULT_USER: String
- DEFAULT_PASSWORD: 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_CONNECTION_RETRY_DELAY: long
- DEFAULT_CONNECTION_RETRIES: Integer
- connectionRetries: Integer
- connectionRetryDelay: 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
- getConnectionRetryDelay(): long
- RabbitMQOptions(JsonObject): void
- RabbitMQOptions(RabbitMQOptions): void
- getConnectionRetries(): Integer
- setConnectionRetries(Integer): RabbitMQOptions
- setConnectionRetryDelay(long): RabbitMQOptions
- 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
- RabbitMQOptionsConverter
-
impl
-
BasicPropertiesImpl
- contentType: String
- contentEncoding: String
- headers: Map<String, Object>
- deliveryMode: Integer
- priority: Integer
- correlationId: String
- replyTo: String
- expiration: String
- messageId: String
- timestamp: Date
- type: String
- userId: String
- appId: String
- clusterId: String
- BasicPropertiesImpl(String, String, Map<String, Object>, Integer, Integer, String, String, String, String, Date, String, String, String, String): void
- contentType(): String
- contentEncoding(): String
- headers(): Map<String, Object>
- deliveryMode(): Integer
- priority(): Integer
- correlationId(): String
- replyTo(): String
- expiration(): String
- messageId(): String
- timestamp(): Long
- type(): String
- userId(): String
- appId(): String
- clusterId(): String
- ConsumerHandler
- EnvelopeImpl
- QueueConsumerHandler
-
RabbitMQClientImpl
- log: Logger
- emptyConfig: JsonObject
- vertx: Vertx
- config: RabbitMQOptions
- retries: Integer
- includeProperties: boolean
- connection: Connection
- channel: Channel
- channelConfirms: boolean
- RabbitMQClientImpl(Vertx, RabbitMQOptions): void
- newConnection(RabbitMQOptions): Connection
- isConnected(): boolean
- isOpenChannel(): boolean
- basicAck(long, boolean, Handler<AsyncResult<JsonObject>>): void
- basicNack(long, boolean, boolean, Handler<AsyncResult<JsonObject>>): void
- basicConsumer(String, QueueOptions, Handler<AsyncResult<RabbitMQConsumer>>): void
- basicConsume(String, String, Handler<AsyncResult<String>>): void
- basicConsume(String, String, boolean, Handler<AsyncResult<String>>): void
- basicConsume(String, String, boolean, Handler<AsyncResult<String>>, Handler<Throwable>): void
- basicCancel(String): void
- basicCancel(String, Handler<AsyncResult<Void>>): void
- basicGet(String, boolean, Handler<AsyncResult<JsonObject>>): void
- basicPublish(String, String, JsonObject, Handler<AsyncResult<Void>>): void
- confirmSelect(Handler<AsyncResult<Void>>): void
- waitForConfirms(Handler<AsyncResult<Void>>): void
- waitForConfirms(long, Handler<AsyncResult<Void>>): void
- basicQos(int, int, boolean, Handler<AsyncResult<Void>>): void
- exchangeDeclare(String, String, boolean, boolean, Handler<AsyncResult<Void>>): void
- exchangeDeclare(String, String, boolean, boolean, Map<String, String>, Handler<AsyncResult<Void>>): void
- exchangeDeclare(String, String, boolean, boolean, JsonObject, Handler<AsyncResult<Void>>): void
- exchangeDelete(String, Handler<AsyncResult<Void>>): void
- exchangeBind(String, String, String, Handler<AsyncResult<Void>>): void
- exchangeUnbind(String, String, String, Handler<AsyncResult<Void>>): void
- queueDeclareAuto(Handler<AsyncResult<JsonObject>>): void
- queueDeclare(String, boolean, boolean, boolean, Handler<AsyncResult<JsonObject>>): void
- queueDeclare(String, boolean, boolean, boolean, Map<String, String>, Handler<AsyncResult<JsonObject>>): void
- queueDeclare(String, boolean, boolean, boolean, JsonObject, Handler<AsyncResult<JsonObject>>): void
- queueDelete(String, Handler<AsyncResult<JsonObject>>): void
- queueDeleteIf(String, boolean, boolean, Handler<AsyncResult<JsonObject>>): void
- queueBind(String, String, String, Handler<AsyncResult<Void>>): void
- messageCount(String, Handler<AsyncResult<Long>>): void
- start(Handler<AsyncResult<Void>>): void
- start(int, Handler<AsyncResult<Void>>): void
- stop(Handler<AsyncResult<Void>>): void
- forChannel(Handler<AsyncResult<Object>>, ChannelHandler<Object>): void
- connect(): void
- disconnect(): void
- toArgumentsMap(Map<String, String>): Map<String, Object>
- shutdownCompleted(ShutdownSignalException): void
- ChannelHandler
-
RabbitMQConsumerImpl
- log: Logger
- exceptionHandler: Handler<Throwable>
- endHandler: Handler<Void>
- consumerHandler: QueueConsumerHandler
- keepMostRecent: boolean
- pending: InboundBuffer<RabbitMQMessage>
- maxQueueSize: int
- RabbitMQConsumerImpl(Context, QueueConsumerHandler, QueueOptions): void
- exceptionHandler(Handler<Throwable>): RabbitMQConsumer
- handler(Handler<RabbitMQMessage>): RabbitMQConsumer
- pause(): RabbitMQConsumer
- resume(): RabbitMQConsumer
- fetch(long): ReadStream<RabbitMQMessage>
- endHandler(Handler<Void>): RabbitMQConsumer
- consumerTag(): String
- cancel(): void
- cancel(Handler<AsyncResult<Void>>): void
- isPaused(): boolean
- handleMessage(RabbitMQMessage): void
- handleException(Throwable): void
- handleEnd(): void
- RabbitMQMessageImpl
-
Utils
- toJson(DeclareOk): JsonObject
- populate(JsonObject, Envelope): void
- 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
-
BasicPropertiesImpl
-
rabbitmq
-
vertx