Package | Description |
---|---|
io.vertx.amqp.bridge |
= Vert.x AMQP Bridge
This component provides AMQP 1.0 producer and consumer support via a bridging layer implementing the Vert.x event bus
MessageProducer and MessageConsumer APIs over the top of link:https://github.com/vert-x3/vertx-proton/[vertx-proton].
|
io.vertx.rxjava.amqp.bridge |
Modifier and Type | Method and Description |
---|---|
AmqpBridgeOptions |
AmqpBridgeOptions.addCrlPath(String crlPath) |
AmqpBridgeOptions |
AmqpBridgeOptions.addCrlValue(io.vertx.core.buffer.Buffer crlValue) |
AmqpBridgeOptions |
AmqpBridgeOptions.addEnabledCipherSuite(String suite) |
AmqpBridgeOptions |
AmqpBridgeOptions.addEnabledSaslMechanism(String saslMechanism) |
AmqpBridgeOptions |
AmqpBridgeOptions.addEnabledSecureTransportProtocol(String protocol) |
AmqpBridgeOptions |
AmqpBridgeOptions.setConnectTimeout(int connectTimeout) |
AmqpBridgeOptions |
AmqpBridgeOptions.setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm) |
AmqpBridgeOptions |
AmqpBridgeOptions.setIdleTimeout(int idleTimeout) |
AmqpBridgeOptions |
AmqpBridgeOptions.setJdkSslEngineOptions(io.vertx.core.net.JdkSSLEngineOptions sslEngineOptions) |
AmqpBridgeOptions |
AmqpBridgeOptions.setKeyCertOptions(io.vertx.core.net.KeyCertOptions options) |
AmqpBridgeOptions |
AmqpBridgeOptions.setKeyStoreOptions(io.vertx.core.net.JksOptions options) |
AmqpBridgeOptions |
AmqpBridgeOptions.setLogActivity(boolean logEnabled) |
AmqpBridgeOptions |
AmqpBridgeOptions.setMetricsName(String metricsName) |
AmqpBridgeOptions |
AmqpBridgeOptions.setOpenSslEngineOptions(io.vertx.core.net.OpenSSLEngineOptions sslEngineOptions) |
AmqpBridgeOptions |
AmqpBridgeOptions.setPemKeyCertOptions(io.vertx.core.net.PemKeyCertOptions options) |
AmqpBridgeOptions |
AmqpBridgeOptions.setPemTrustOptions(io.vertx.core.net.PemTrustOptions options) |
AmqpBridgeOptions |
AmqpBridgeOptions.setPfxKeyCertOptions(io.vertx.core.net.PfxOptions options) |
AmqpBridgeOptions |
AmqpBridgeOptions.setPfxTrustOptions(io.vertx.core.net.PfxOptions options) |
AmqpBridgeOptions |
AmqpBridgeOptions.setProxyOptions(io.vertx.core.net.ProxyOptions proxyOptions) |
AmqpBridgeOptions |
AmqpBridgeOptions.setReceiveBufferSize(int receiveBufferSize) |
AmqpBridgeOptions |
AmqpBridgeOptions.setReconnectAttempts(int attempts) |
AmqpBridgeOptions |
AmqpBridgeOptions.setReconnectInterval(long interval) |
AmqpBridgeOptions |
AmqpBridgeOptions.setReuseAddress(boolean reuseAddress) |
AmqpBridgeOptions |
AmqpBridgeOptions.setSendBufferSize(int sendBufferSize) |
AmqpBridgeOptions |
AmqpBridgeOptions.setSoLinger(int soLinger) |
AmqpBridgeOptions |
AmqpBridgeOptions.setSsl(boolean ssl) |
AmqpBridgeOptions |
AmqpBridgeOptions.setSslEngineOptions(io.vertx.core.net.SSLEngineOptions sslEngineOptions) |
AmqpBridgeOptions |
AmqpBridgeOptions.setTcpKeepAlive(boolean tcpKeepAlive) |
AmqpBridgeOptions |
AmqpBridgeOptions.setTcpNoDelay(boolean tcpNoDelay) |
AmqpBridgeOptions |
AmqpBridgeOptions.setTrafficClass(int trafficClass) |
AmqpBridgeOptions |
AmqpBridgeOptions.setTrustAll(boolean trustAll) |
AmqpBridgeOptions |
AmqpBridgeOptions.setTrustOptions(io.vertx.core.net.TrustOptions options) |
AmqpBridgeOptions |
AmqpBridgeOptions.setTrustStoreOptions(io.vertx.core.net.JksOptions options) |
AmqpBridgeOptions |
AmqpBridgeOptions.setUseAlpn(boolean useAlpn) |
AmqpBridgeOptions |
AmqpBridgeOptions.setUsePooledBuffers(boolean usePooledBuffers) |
Modifier and Type | Method and Description |
---|---|
static AmqpBridge |
AmqpBridge.create(io.vertx.core.Vertx vertx,
AmqpBridgeOptions options)
Creates a Bridge with the given options.
|
static void |
AmqpBridgeOptionsConverter.fromJson(io.vertx.core.json.JsonObject json,
AmqpBridgeOptions obj) |
static void |
AmqpBridgeOptionsConverter.toJson(AmqpBridgeOptions obj,
io.vertx.core.json.JsonObject json) |
Modifier and Type | Method and Description |
---|---|
static AmqpBridge |
AmqpBridge.create(io.vertx.rxjava.core.Vertx vertx,
AmqpBridgeOptions options)
Creates a Bridge with the given options.
|
Copyright © 2016. All rights reserved.