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
10000
public static final Integer DEFAULT_RECONNECT_ATTEMPTS
Integer.MAX_VALUE
public 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 © 2023 Eclipse. All rights reserved.