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
-
VertxAmqpBridgeExamples
- example1(Vertx): void
- example2(Vertx): void
- example3(MessageProducer<JsonObject>): void
- example4(JsonObject): void
- example5(MessageProducer<JsonObject>): void
- example6(MessageProducer<JsonObject>): void
- example7(MessageConsumer<JsonObject>): void
- example8(Vertx): void
- example9(Vertx): void
- example10(MessageProducer<JsonObject>): void
- example11(MessageConsumer<JsonObject>): void
-
VertxAmqpBridgeExamples
-
io
-
vertx
-
amqpbridge
-
AmqpBridge
- create(Vertx): AmqpBridge
- create(Vertx, AmqpBridgeOptions): AmqpBridge
- start(String, int, String, String, Handler<AsyncResult<AmqpBridge>>): void
- start(String, int, Handler<AsyncResult<AmqpBridge>>): void
- createConsumer(String): MessageConsumer<Object>
- createProducer(String): MessageProducer<Object>
- close(Handler<AsyncResult<Void>>): void
- endHandler(Handler<Void>): void
-
AmqpBridgeOptions
- getContainerId(): String
- replyHandlingSupport: boolean
- containerId: String
- vhost: String
- AmqpBridgeOptions(): void
- AmqpBridgeOptions(JsonObject): void
- toJson(): JsonObject
- setContainerId(String): AmqpBridgeOptions
- setVhost(String): AmqpBridgeOptions
- getVhost(): String
- setReplyHandlingSupport(boolean): AmqpBridgeOptions
- isReplyHandlingSupport(): boolean
- addEnabledSaslMechanism(String): AmqpBridgeOptions
- setHeartbeat(int): AmqpBridgeOptions
- setSendBufferSize(int): AmqpBridgeOptions
- setReceiveBufferSize(int): AmqpBridgeOptions
- setReuseAddress(boolean): AmqpBridgeOptions
- setTrafficClass(int): AmqpBridgeOptions
- setTcpNoDelay(boolean): AmqpBridgeOptions
- setTcpKeepAlive(boolean): AmqpBridgeOptions
- setSoLinger(int): AmqpBridgeOptions
- setReusePort(boolean): AmqpBridgeOptions
- setTcpCork(boolean): AmqpBridgeOptions
- setTcpFastOpen(boolean): AmqpBridgeOptions
- setTcpQuickAck(boolean): AmqpBridgeOptions
- setUsePooledBuffers(boolean): AmqpBridgeOptions
- setIdleTimeout(int): AmqpBridgeOptions
- setIdleTimeoutUnit(TimeUnit): AmqpBridgeOptions
- setSsl(boolean): AmqpBridgeOptions
- setKeyStoreOptions(JksOptions): AmqpBridgeOptions
- setPfxKeyCertOptions(PfxOptions): AmqpBridgeOptions
- setPemKeyCertOptions(PemKeyCertOptions): AmqpBridgeOptions
- setTrustStoreOptions(JksOptions): AmqpBridgeOptions
- setPemTrustOptions(PemTrustOptions): AmqpBridgeOptions
- setPfxTrustOptions(PfxOptions): AmqpBridgeOptions
- addEnabledCipherSuite(String): AmqpBridgeOptions
- addCrlPath(String): AmqpBridgeOptions
- addCrlValue(Buffer): AmqpBridgeOptions
- setTrustAll(boolean): AmqpBridgeOptions
- setConnectTimeout(int): AmqpBridgeOptions
- setReconnectAttempts(int): AmqpBridgeOptions
- setReconnectInterval(long): AmqpBridgeOptions
- setUseAlpn(boolean): AmqpBridgeOptions
- addEnabledSecureTransportProtocol(String): AmqpBridgeOptions
- removeEnabledSecureTransportProtocol(String): AmqpBridgeOptions
- setEnabledSecureTransportProtocols(Set<String>): AmqpBridgeOptions
- setHostnameVerificationAlgorithm(String): AmqpBridgeOptions
- setKeyCertOptions(KeyCertOptions): AmqpBridgeOptions
- setLogActivity(boolean): AmqpBridgeOptions
- setMetricsName(String): AmqpBridgeOptions
- setProxyOptions(ProxyOptions): AmqpBridgeOptions
- setTrustOptions(TrustOptions): AmqpBridgeOptions
- setJdkSslEngineOptions(JdkSSLEngineOptions): AmqpBridgeOptions
- setOpenSslEngineOptions(OpenSSLEngineOptions): AmqpBridgeOptions
- setSslEngineOptions(SSLEngineOptions): AmqpBridgeOptions
- setLocalAddress(String): AmqpBridgeOptions
- hashCode(): int
- equals(Object): boolean
- setVirtualHost(String): AmqpBridgeOptions
- setSniServerName(String): AmqpBridgeOptions
- setMaxFrameSize(int): AmqpBridgeOptions
- AmqpBridgeOptionsConverter
-
AmqpConstants
- BODY_TYPE: String
- BODY_TYPE_VALUE: String
- BODY_TYPE_DATA: String
- BODY_TYPE_SEQUENCE: String
- HEADER: String
- BODY: String
- PROPERTIES: String
- APPLICATION_PROPERTIES: String
- MESSAGE_ANNOTATIONS: String
- HEADER_DURABLE: String
- HEADER_PRIORITY: String
- HEADER_TTL: String
- HEADER_FIRST_ACQUIRER: String
- HEADER_DELIVERY_COUNT: String
- PROPERTIES_TO: String
- PROPERTIES_REPLY_TO: String
- PROPERTIES_MESSAGE_ID: String
- PROPERTIES_CORRELATION_ID: String
- PROPERTIES_SUBJECT: String
- PROPERTIES_GROUP_ID: String
- PROPERTIES_GROUP_SEQUENCE: String
- PROPERTIES_REPLY_TO_GROUP_ID: String
- PROPERTIES_CONTENT_TYPE: String
- PROPERTIES_CONTENT_ENCODING: String
- PROPERTIES_CREATION_TIME: String
- PROPERTIES_ABSOLUTE_EXPIRY_TIME: String
- PROPERTIES_USER_ID: String
-
impl
-
AmqpBridgeImpl
- vertx: Vertx
- bridgeContext: Context
- options: AmqpBridgeOptions
- client: ProtonClient
- connection: ProtonConnection
- replyToConsumer: ProtonReceiver
- replyToConsumerAddress: String
- replySender: AmqpProducerImpl
- replyToMapping: Map<String, Handler<Object>>
- translator: MessageTranslatorImpl
- started: AtomicBoolean
- closed: AtomicBoolean
- endHandler: Handler<Void>
- AmqpBridgeImpl(Vertx, AmqpBridgeOptions): void
- LOG: Logger
- start(String, int, Handler<AsyncResult<AmqpBridge>>): void
- start(String, int, String, String, Handler<AsyncResult<AmqpBridge>>): void
- startImpl(String, int, String, String, Handler<AsyncResult<AmqpBridge>>): void
- endHandlerImpl(): void
- createConsumer(String): MessageConsumer<JsonObject>
- createProducer(String): MessageProducer<JsonObject>
- close(Handler<AsyncResult<Void>>): void
- shutdownImpl(Handler<AsyncResult<Void>>): void
- disconnectImpl(): void
- isLocalOpen(ProtonConnection): boolean
- isRemoteOpen(ProtonConnection): boolean
- endHandler(Handler<Void>): void
- registerReplyToHandler(Message, Handler<AsyncResult<Message<Object>>>): void
- verifyReplyToAddressAvailable(): void
- handleIncomingMessageReply(ProtonDelivery, Message): void
- sendReply(Message, JsonObject, Handler<AsyncResult<Message<Object>>>): void
- onContextEventLoop(): boolean
- runOnContext(boolean, Handler<Void>): void
-
AmqpConsumerImpl
- LOG: Logger
- bridge: AmqpBridgeImpl
- receiver: ProtonReceiver
- amqpAddress: String
- translator: MessageTranslatorImpl
- buffered: Queue<AmqpMessageImpl>
- handler: Handler<Message<JsonObject>>
- demand: long
- closed: boolean
- exceptionHandler: Handler<Throwable>
- endHandler: Handler<Void>
- initialCreditGiven: boolean
- initialCredit: int
- AmqpConsumerImpl(AmqpBridgeImpl, ProtonConnection, String): void
- handleMessage(AmqpMessageImpl): void
- deliverMessageToHandler(AmqpMessageImpl, Handler<Message<JsonObject>>): void
- scheduleBufferedMessageDelivery(): void
- exceptionHandler(Handler<Throwable>): MessageConsumer<JsonObject>
- handler(Handler<Message<JsonObject>>): MessageConsumer<JsonObject>
- pause(): MessageConsumer<JsonObject>
- fetch(long): MessageConsumer<JsonObject>
- resume(): MessageConsumer<JsonObject>
- endHandler(Handler<Void>): MessageConsumer<JsonObject>
- bodyStream(): ReadStream<JsonObject>
- isRegistered(): boolean
- address(): String
- setMaxBufferedMessages(int): MessageConsumer<JsonObject>
- getMaxBufferedMessages(): int
- completionHandler(Handler<AsyncResult<Void>>): void
- unregister(): void
- unregister(Handler<AsyncResult<Void>>): void
-
AmqpMessageImpl
- body: JsonObject
- bridge: AmqpBridgeImpl
- protonMessage: Message
- delivery: ProtonDelivery
- amqpAddress: String
- amqpReplyAddress: String
- AmqpMessageImpl(JsonObject, AmqpBridgeImpl, Message, ProtonDelivery, String, String): void
- address(): String
- headers(): MultiMap
- body(): JsonObject
- replyAddress(): String
- isSend(): boolean
- doReply(Object, Handler<AsyncResult<Message<Object>>>): void
- reply(Object): void
- reply(Object, Handler<AsyncResult<Message<Object>>>): void
- reply(Object, DeliveryOptions): void
- reply(Object, DeliveryOptions, Handler<AsyncResult<Message<Object>>>): void
- fail(int, String): void
- accept(): void
-
AmqpProducerImpl
- sender: ProtonSender
- translator: MessageTranslatorImpl
- bridge: AmqpBridgeImpl
- amqpAddress: String
- closed: boolean
- exceptionHandler: Handler<Throwable>
- drainHandler: Handler<Void>
- remoteCredit: long
- AmqpProducerImpl(AmqpBridgeImpl, ProtonConnection, String): void
- writeQueueFull(): boolean
- send(JsonObject): MessageProducer<JsonObject>
- send(JsonObject, Handler<AsyncResult<Message<Object>>>): MessageProducer<JsonObject>
- doSend(JsonObject, Handler<AsyncResult<Void>>, Handler<AsyncResult<Message<Object>>>, String): MessageProducer<JsonObject>
- exceptionHandler(Handler<Throwable>): MessageProducer<JsonObject>
- write(JsonObject): MessageProducer<JsonObject>
- write(JsonObject, Handler<AsyncResult<Void>>): MessageProducer<JsonObject>
- setWriteQueueMaxSize(int): MessageProducer<JsonObject>
- drainHandler(Handler<Void>): MessageProducer<JsonObject>
- deliveryOptions(DeliveryOptions): MessageProducer<JsonObject>
- address(): String
- end(): void
- end(Handler<AsyncResult<Void>>): void
- close(): void
- close(Handler<AsyncResult<Void>>): void
- BridgeMetaDataSupportImpl
-
MessageTranslatorImpl
- EMPTY_BODY_SECTION: AmqpValue
- convertToJsonObject(Message): JsonObject
- createJsonHeader(Header): JsonObject
- createJsonMessageAnnotations(Map<Symbol, Object>): JsonObject
- createJsonProperties(Properties): JsonObject
- createJsonApplicationProperties(Map<String, Object>): JsonObject
- translateToJsonCompatible(Object): Object
- convertToAmqpMessage(JsonObject): Message
- createAmqpHeader(JsonObject): Header
- createAmqpMessageAnnotations(JsonObject): MessageAnnotations
- createAmqpApplicationProperties(JsonObject): ApplicationProperties
- translateToAmqpCompatible(Object): Object
- createAmqpProperties(JsonObject): Properties
-
AmqpBridgeImpl
-
AmqpBridge
-
amqpbridge
-
vertx