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
-
-
-
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
-
-
-
-
amqpbridge
-
vertx