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.setHostnameVerificationAlgorithm(String algorithm) |
|
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.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.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.
|