Package com.rabbitmq.client.impl
Class ConnectionParams
java.lang.Object
com.rabbitmq.client.impl.ConnectionParams
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate int
private boolean
private Predicate
<ShutdownSignalException> private ExecutorService
private CredentialsProvider
private CredentialsRefreshService
private ErrorOnWriteListener
private ExceptionHandler
private int
private ScheduledExecutorService
private int
private long
private RecoveredQueueNameSupplier
private RecoveryDelayHandler
private int
private int
private int
private SaslConfig
private ExecutorService
private int
private ThreadFactory
private boolean
private ExecutorService
private TopologyRecoveryFilter
private RetryHandler
private TrafficListener
private String
private int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
int
int
int
long
Get the recovery delay handler.int
int
int
int
Get the topology recovery executor.int
boolean
void
setChannelRpcTimeout
(int channelRpcTimeout) void
setChannelShouldCheckRpcResponseType
(boolean channelShouldCheckRpcResponseType) void
setClientProperties
(Map<String, Object> clientProperties) void
setConnectionRecoveryTriggeringCondition
(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition) void
setConsumerWorkServiceExecutor
(ExecutorService consumerWorkServiceExecutor) void
setCredentialsProvider
(CredentialsProvider credentialsProvider) void
setCredentialsRefreshService
(CredentialsRefreshService credentialsRefreshService) void
setErrorOnWriteListener
(ErrorOnWriteListener errorOnWriteListener) void
setExceptionHandler
(ExceptionHandler exceptionHandler) void
setHandshakeTimeout
(int timeout) void
setHeartbeatExecutor
(ScheduledExecutorService heartbeatExecutor) void
setMaxInboundMessageBodySize
(int maxInboundMessageBodySize) void
setNetworkRecoveryInterval
(long networkRecoveryInterval) void
setRecoveredQueueNameSupplier
(RecoveredQueueNameSupplier recoveredQueueNameSupplier) void
setRecoveryDelayHandler
(RecoveryDelayHandler recoveryDelayHandler) void
setRequestedChannelMax
(int requestedChannelMax) void
setRequestedFrameMax
(int requestedFrameMax) void
setRequestedHeartbeat
(int requestedHeartbeat) void
setSaslConfig
(SaslConfig saslConfig) void
setShutdownExecutor
(ExecutorService shutdownExecutor) void
setShutdownTimeout
(int shutdownTimeout) void
setThreadFactory
(ThreadFactory threadFactory) void
setTopologyRecovery
(boolean topologyRecovery) void
setTopologyRecoveryExecutor
(ExecutorService topologyRecoveryExecutor) void
setTopologyRecoveryFilter
(TopologyRecoveryFilter topologyRecoveryFilter) void
setTopologyRecoveryRetryHandler
(RetryHandler topologyRecoveryRetryHandler) void
setTrafficListener
(TrafficListener trafficListener) void
setVirtualHost
(String virtualHost) void
setWorkPoolTimeout
(int workPoolTimeout)
-
Field Details
-
credentialsProvider
-
consumerWorkServiceExecutor
-
heartbeatExecutor
-
shutdownExecutor
-
virtualHost
-
clientProperties
-
requestedFrameMax
private int requestedFrameMax -
requestedChannelMax
private int requestedChannelMax -
requestedHeartbeat
private int requestedHeartbeat -
handshakeTimeout
private int handshakeTimeout -
shutdownTimeout
private int shutdownTimeout -
saslConfig
-
networkRecoveryInterval
private long networkRecoveryInterval -
recoveryDelayHandler
-
topologyRecovery
private boolean topologyRecovery -
topologyRecoveryExecutor
-
channelRpcTimeout
private int channelRpcTimeout -
channelShouldCheckRpcResponseType
private boolean channelShouldCheckRpcResponseType -
errorOnWriteListener
-
workPoolTimeout
private int workPoolTimeout -
topologyRecoveryFilter
-
connectionRecoveryTriggeringCondition
-
topologyRecoveryRetryHandler
-
recoveredQueueNameSupplier
-
exceptionHandler
-
threadFactory
-
trafficListener
-
credentialsRefreshService
-
maxInboundMessageBodySize
private int maxInboundMessageBodySize
-
-
Constructor Details
-
ConnectionParams
public ConnectionParams()
-
-
Method Details
-
getCredentialsProvider
-
getConsumerWorkServiceExecutor
-
getVirtualHost
-
getClientProperties
-
getRequestedFrameMax
public int getRequestedFrameMax() -
getRequestedChannelMax
public int getRequestedChannelMax() -
getRequestedHeartbeat
public int getRequestedHeartbeat() -
getHandshakeTimeout
public int getHandshakeTimeout() -
setHandshakeTimeout
public void setHandshakeTimeout(int timeout) -
getShutdownTimeout
public int getShutdownTimeout() -
getSaslConfig
-
getExceptionHandler
-
getNetworkRecoveryInterval
public long getNetworkRecoveryInterval() -
getRecoveryDelayHandler
Get the recovery delay handler.- Returns:
- recovery delay handler or if none was set a
RecoveryDelayHandler.DefaultRecoveryDelayHandler
will be returned with a delay ofgetNetworkRecoveryInterval()
.
-
isTopologyRecoveryEnabled
public boolean isTopologyRecoveryEnabled() -
getTopologyRecoveryExecutor
Get the topology recovery executor. If null, the main connection thread should be used.- Returns:
- executor. May be null.
-
getThreadFactory
-
getChannelRpcTimeout
public int getChannelRpcTimeout() -
channelShouldCheckRpcResponseType
public boolean channelShouldCheckRpcResponseType() -
setCredentialsProvider
-
setConsumerWorkServiceExecutor
-
setVirtualHost
-
setClientProperties
-
setRequestedFrameMax
public void setRequestedFrameMax(int requestedFrameMax) -
setRequestedChannelMax
public void setRequestedChannelMax(int requestedChannelMax) -
setRequestedHeartbeat
public void setRequestedHeartbeat(int requestedHeartbeat) -
setShutdownTimeout
public void setShutdownTimeout(int shutdownTimeout) -
setSaslConfig
-
setNetworkRecoveryInterval
public void setNetworkRecoveryInterval(long networkRecoveryInterval) -
setRecoveryDelayHandler
-
setTopologyRecovery
public void setTopologyRecovery(boolean topologyRecovery) -
setTopologyRecoveryExecutor
-
setExceptionHandler
-
setThreadFactory
-
getShutdownExecutor
-
setShutdownExecutor
-
getHeartbeatExecutor
-
setHeartbeatExecutor
-
setChannelRpcTimeout
public void setChannelRpcTimeout(int channelRpcTimeout) -
setChannelShouldCheckRpcResponseType
public void setChannelShouldCheckRpcResponseType(boolean channelShouldCheckRpcResponseType) -
setErrorOnWriteListener
-
getErrorOnWriteListener
-
setWorkPoolTimeout
public void setWorkPoolTimeout(int workPoolTimeout) -
getWorkPoolTimeout
public int getWorkPoolTimeout() -
setTopologyRecoveryFilter
-
getTopologyRecoveryFilter
-
setConnectionRecoveryTriggeringCondition
public void setConnectionRecoveryTriggeringCondition(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition) -
getConnectionRecoveryTriggeringCondition
-
setTopologyRecoveryRetryHandler
-
getTopologyRecoveryRetryHandler
-
setRecoveredQueueNameSupplier
-
getRecoveredQueueNameSupplier
-
setTrafficListener
-
getTrafficListener
-
setCredentialsRefreshService
-
getCredentialsRefreshService
-
getMaxInboundMessageBodySize
public int getMaxInboundMessageBodySize() -
setMaxInboundMessageBodySize
public void setMaxInboundMessageBodySize(int maxInboundMessageBodySize)
-