Package io.vertx.rabbitmq
Class RabbitMQPublisherOptions
- java.lang.Object
-
- io.vertx.rabbitmq.RabbitMQPublisherOptions
-
public class RabbitMQPublisherOptions extends Object
RabbitMQ client options, most- Author:
- Julien Viet
-
-
Field Summary
Fields Modifier and Type Field Description static IntegerDEFAULT_RECONNECT_ATTEMPTSThe default connection retries =Integer.MAX_VALUEstatic longDEFAULT_RECONNECT_INTERVALThe default connection retry delay =10000
-
Constructor Summary
Constructors Constructor Description RabbitMQPublisherOptions()RabbitMQPublisherOptions(JsonObject json)RabbitMQPublisherOptions(RabbitMQPublisherOptions that)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intgetMaxInternalQueueSize()IntegergetReconnectAttempts()longgetReconnectInterval()RabbitMQPublisherOptionssetMaxInternalQueueSize(int maxInternalQueueSize)RabbitMQPublisherOptionssetReconnectAttempts(Integer reconnectAttempts)Set the number of reconnect attempts to attempt when connecting, thenullvalue disables it.RabbitMQPublisherOptionssetReconnectInterval(long reconnectInterval)Set the delay in milliseconds between connection retries.
-
-
-
Field Detail
-
DEFAULT_RECONNECT_INTERVAL
public static final long DEFAULT_RECONNECT_INTERVAL
The default connection retry delay =10000- See Also:
- Constant Field Values
-
DEFAULT_RECONNECT_ATTEMPTS
public static final Integer DEFAULT_RECONNECT_ATTEMPTS
The default connection retries =Integer.MAX_VALUE
-
-
Constructor Detail
-
RabbitMQPublisherOptions
public RabbitMQPublisherOptions()
-
RabbitMQPublisherOptions
public RabbitMQPublisherOptions(JsonObject json)
-
RabbitMQPublisherOptions
public RabbitMQPublisherOptions(RabbitMQPublisherOptions that)
-
-
Method Detail
-
getReconnectAttempts
public Integer getReconnectAttempts()
- Returns:
- the number of reconnect attempts
-
setReconnectAttempts
public RabbitMQPublisherOptions setReconnectAttempts(Integer reconnectAttempts)
Set the number of reconnect attempts to attempt when connecting, thenullvalue disables it.- Parameters:
reconnectAttempts- the number of retries- Returns:
- a reference to this, so the API can be used fluently
-
getReconnectInterval
public long getReconnectInterval()
- Returns:
- the delay in milliseconds between connection retries
-
setReconnectInterval
public RabbitMQPublisherOptions setReconnectInterval(long reconnectInterval)
Set the delay in milliseconds between connection retries.- Parameters:
reconnectInterval- the delay in milliseconds- Returns:
- a reference to this, so the API can be used fluently
-
getMaxInternalQueueSize
public int getMaxInternalQueueSize()
- Returns:
- the size of internal queue
-
setMaxInternalQueueSize
public RabbitMQPublisherOptions setMaxInternalQueueSize(int maxInternalQueueSize)
- Parameters:
maxInternalQueueSize- the size of internal queue- Returns:
- a reference to this, so the API can be used fluently
-
-