public class RabbitMQPublisherOptions extends Object
| Modifier and Type | Field and Description |
|---|---|
static Integer |
DEFAULT_RECONNECT_ATTEMPTS
The default connection retries =
Integer.MAX_VALUE |
static long |
DEFAULT_RECONNECT_INTERVAL
The default connection retry delay =
10000 |
| Constructor and Description |
|---|
RabbitMQPublisherOptions() |
RabbitMQPublisherOptions(JsonObject json) |
RabbitMQPublisherOptions(RabbitMQPublisherOptions that) |
| Modifier and Type | Method and Description |
|---|---|
int |
getMaxInternalQueueSize() |
Integer |
getReconnectAttempts() |
long |
getReconnectInterval() |
RabbitMQPublisherOptions |
setMaxInternalQueueSize(int maxInternalQueueSize) |
RabbitMQPublisherOptions |
setReconnectAttempts(Integer reconnectAttempts)
Set the number of reconnect attempts to attempt when connecting, the
null value disables it. |
RabbitMQPublisherOptions |
setReconnectInterval(long reconnectInterval)
Set the delay in milliseconds between connection retries.
|
public static final long DEFAULT_RECONNECT_INTERVAL
10000public static final Integer DEFAULT_RECONNECT_ATTEMPTS
Integer.MAX_VALUEpublic RabbitMQPublisherOptions()
public RabbitMQPublisherOptions(JsonObject json)
public RabbitMQPublisherOptions(RabbitMQPublisherOptions that)
public Integer getReconnectAttempts()
public RabbitMQPublisherOptions setReconnectAttempts(Integer reconnectAttempts)
null value disables it.reconnectAttempts - the number of retriespublic long getReconnectInterval()
public RabbitMQPublisherOptions setReconnectInterval(long reconnectInterval)
reconnectInterval - the delay in millisecondspublic int getMaxInternalQueueSize()
public RabbitMQPublisherOptions setMaxInternalQueueSize(int maxInternalQueueSize)
maxInternalQueueSize - the size of internal queueCopyright © 2022 Eclipse. All rights reserved.