Package | Description |
---|---|
io.vertx.rabbitmq | |
io.vertx.reactivex.rabbitmq | |
io.vertx.rxjava.rabbitmq | |
io.vertx.rxjava3.rabbitmq |
Modifier and Type | Method and Description |
---|---|
RabbitMQOptions |
RabbitMQOptions.setAddresses(List<com.rabbitmq.client.Address> addresses)
Set multiple addresses for cluster mode.
|
RabbitMQOptions |
RabbitMQOptions.setAutomaticRecoveryEnabled(boolean automaticRecoveryEnabled)
Enables or disables automatic connection recovery.
|
RabbitMQOptions |
RabbitMQOptions.setAutomaticRecoveryOnInitialConnection(boolean automaticRecoveryOnInitialConnection)
Enable or disable automatic recovery on initial connections.
|
RabbitMQOptions |
RabbitMQOptions.setConnectionName(String connectionName) |
RabbitMQOptions |
RabbitMQOptions.setConnectionTimeout(int connectionTimeout)
Set the TCP connection timeout, in milliseconds,
zero for infinite). |
RabbitMQOptions |
RabbitMQOptions.setCredentialsProvider(com.rabbitmq.client.impl.CredentialsProvider credentialsProvider)
Provides a RabbitMQ credentials provider for using dynamic credentials.
|
RabbitMQOptions |
RabbitMQOptions.setCredentialsRefreshService(com.rabbitmq.client.impl.CredentialsRefreshService credentialsRefreshService)
Provides a RabbitMQ credentials refresh service for refreshing dynamic credentials.
|
RabbitMQOptions |
RabbitMQOptions.setHandshakeTimeout(int handshakeTimeout)
Set the AMQP 0-9-1 protocol handshake timeout, in milliseconds
|
RabbitMQOptions |
RabbitMQOptions.setHost(String host)
Set the default host to use for connections.
|
RabbitMQOptions |
RabbitMQOptions.setIncludeProperties(boolean includeProperties)
Set wether to include properties when a broker message is passed on the event bus
|
RabbitMQOptions |
RabbitMQOptions.setKeyCertOptions(KeyCertOptions options) |
RabbitMQOptions |
RabbitMQOptions.setKeyStoreOptions(JksOptions options) |
RabbitMQOptions |
RabbitMQOptions.setMetricsCollector(com.rabbitmq.client.MetricsCollector metricsCollector)
Provides a metrics collector for RabbitMQ.
|
RabbitMQOptions |
RabbitMQOptions.setNetworkRecoveryInterval(long networkRecoveryInterval)
Set how long in milliseconds will automatic recovery wait before attempting to reconnect, default is
5000 |
RabbitMQOptions |
RabbitMQOptions.setPassword(String password)
Set the password to use when connecting to the broker.
|
RabbitMQOptions |
RabbitMQOptions.setPemKeyCertOptions(PemKeyCertOptions options) |
RabbitMQOptions |
RabbitMQOptions.setPemTrustOptions(PemTrustOptions options) |
RabbitMQOptions |
RabbitMQOptions.setPfxKeyCertOptions(PfxOptions options) |
RabbitMQOptions |
RabbitMQOptions.setPfxTrustOptions(PfxOptions options) |
RabbitMQOptions |
RabbitMQOptions.setPort(int port)
Set the default port to use for connections.
|
RabbitMQOptions |
RabbitMQOptions.setReconnectAttempts(int attempts) |
RabbitMQOptions |
RabbitMQOptions.setReconnectInterval(long interval) |
RabbitMQOptions |
RabbitMQOptions.setRequestedChannelMax(int requestedChannelMax)
Set the initially requested maximum channel number,
zero for unlimited. |
RabbitMQOptions |
RabbitMQOptions.setRequestedHeartbeat(int requestedHeartbeat)
Set the initially requested heartbeat interval, in seconds,
zero for none. |
RabbitMQOptions |
RabbitMQOptions.setSaslConfig(com.rabbitmq.client.DefaultSaslConfig saslConfig)
Set the SASL mechanism for rabbitmq authentication
|
RabbitMQOptions |
RabbitMQOptions.setSsl(boolean ssl) |
RabbitMQOptions |
RabbitMQOptions.setTrustAll(boolean trustAll) |
RabbitMQOptions |
RabbitMQOptions.setTrustOptions(TrustOptions options) |
RabbitMQOptions |
RabbitMQOptions.setUri(String uri) |
RabbitMQOptions |
RabbitMQOptions.setUseNio(boolean useNio)
Enables or disables usage of NIO Sockets.
|
RabbitMQOptions |
RabbitMQOptions.setUser(String user)
Set the AMQP user name to use when connecting to the broker.
|
RabbitMQOptions |
RabbitMQOptions.setVirtualHost(String virtualHost)
Set the virtual host to use when connecting to the broker.
|
Modifier and Type | Method and Description |
---|---|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
RabbitMQOptions config)
Create and return a client.
|
static void |
RabbitMQOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
RabbitMQOptions obj) |
static void |
RabbitMQOptionsConverter.toJson(RabbitMQOptions obj,
JsonObject json) |
static void |
RabbitMQOptionsConverter.toJson(RabbitMQOptions obj,
Map<String,Object> json) |
Constructor and Description |
---|
RabbitMQOptions(RabbitMQOptions other) |
Modifier and Type | Method and Description |
---|---|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
RabbitMQOptions config)
Create and return a client.
|
Modifier and Type | Method and Description |
---|---|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
RabbitMQOptions config)
Create and return a client.
|
Modifier and Type | Method and Description |
---|---|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
RabbitMQOptions config)
Create and return a client.
|
Copyright © 2024 Eclipse. All rights reserved.