Package com.rabbitmq.client.impl
Class ConnectionParams
- java.lang.Object
-
- com.rabbitmq.client.impl.ConnectionParams
-
public class ConnectionParams extends java.lang.Object
-
-
Field Summary
-
Constructor Summary
Constructors Constructor Description ConnectionParams()
-
Method Summary
-
-
-
Field Detail
-
credentialsProvider
private CredentialsProvider credentialsProvider
-
consumerWorkServiceExecutor
private java.util.concurrent.ExecutorService consumerWorkServiceExecutor
-
heartbeatExecutor
private java.util.concurrent.ScheduledExecutorService heartbeatExecutor
-
shutdownExecutor
private java.util.concurrent.ExecutorService shutdownExecutor
-
virtualHost
private java.lang.String virtualHost
-
clientProperties
private java.util.Map<java.lang.String,java.lang.Object> clientProperties
-
requestedFrameMax
private int requestedFrameMax
-
requestedChannelMax
private int requestedChannelMax
-
requestedHeartbeat
private int requestedHeartbeat
-
handshakeTimeout
private int handshakeTimeout
-
shutdownTimeout
private int shutdownTimeout
-
saslConfig
private SaslConfig saslConfig
-
networkRecoveryInterval
private long networkRecoveryInterval
-
recoveryDelayHandler
private RecoveryDelayHandler recoveryDelayHandler
-
topologyRecovery
private boolean topologyRecovery
-
topologyRecoveryExecutor
private java.util.concurrent.ExecutorService topologyRecoveryExecutor
-
channelRpcTimeout
private int channelRpcTimeout
-
channelShouldCheckRpcResponseType
private boolean channelShouldCheckRpcResponseType
-
errorOnWriteListener
private ErrorOnWriteListener errorOnWriteListener
-
workPoolTimeout
private int workPoolTimeout
-
topologyRecoveryFilter
private TopologyRecoveryFilter topologyRecoveryFilter
-
connectionRecoveryTriggeringCondition
private java.util.function.Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition
-
topologyRecoveryRetryHandler
private RetryHandler topologyRecoveryRetryHandler
-
recoveredQueueNameSupplier
private RecoveredQueueNameSupplier recoveredQueueNameSupplier
-
exceptionHandler
private ExceptionHandler exceptionHandler
-
threadFactory
private java.util.concurrent.ThreadFactory threadFactory
-
trafficListener
private TrafficListener trafficListener
-
credentialsRefreshService
private CredentialsRefreshService credentialsRefreshService
-
maxInboundMessageBodySize
private int maxInboundMessageBodySize
-
-
Method Detail
-
getCredentialsProvider
public CredentialsProvider getCredentialsProvider()
-
getConsumerWorkServiceExecutor
public java.util.concurrent.ExecutorService getConsumerWorkServiceExecutor()
-
getVirtualHost
public java.lang.String getVirtualHost()
-
getClientProperties
public java.util.Map<java.lang.String,java.lang.Object> 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
public SaslConfig getSaslConfig()
-
getExceptionHandler
public ExceptionHandler getExceptionHandler()
-
getNetworkRecoveryInterval
public long getNetworkRecoveryInterval()
-
getRecoveryDelayHandler
public RecoveryDelayHandler 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
public java.util.concurrent.ExecutorService getTopologyRecoveryExecutor()
Get the topology recovery executor. If null, the main connection thread should be used.- Returns:
- executor. May be null.
-
getThreadFactory
public java.util.concurrent.ThreadFactory getThreadFactory()
-
getChannelRpcTimeout
public int getChannelRpcTimeout()
-
channelShouldCheckRpcResponseType
public boolean channelShouldCheckRpcResponseType()
-
setCredentialsProvider
public void setCredentialsProvider(CredentialsProvider credentialsProvider)
-
setConsumerWorkServiceExecutor
public void setConsumerWorkServiceExecutor(java.util.concurrent.ExecutorService consumerWorkServiceExecutor)
-
setVirtualHost
public void setVirtualHost(java.lang.String virtualHost)
-
setClientProperties
public void setClientProperties(java.util.Map<java.lang.String,java.lang.Object> clientProperties)
-
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
public void setSaslConfig(SaslConfig saslConfig)
-
setNetworkRecoveryInterval
public void setNetworkRecoveryInterval(long networkRecoveryInterval)
-
setRecoveryDelayHandler
public void setRecoveryDelayHandler(RecoveryDelayHandler recoveryDelayHandler)
-
setTopologyRecovery
public void setTopologyRecovery(boolean topologyRecovery)
-
setTopologyRecoveryExecutor
public void setTopologyRecoveryExecutor(java.util.concurrent.ExecutorService topologyRecoveryExecutor)
-
setExceptionHandler
public void setExceptionHandler(ExceptionHandler exceptionHandler)
-
setThreadFactory
public void setThreadFactory(java.util.concurrent.ThreadFactory threadFactory)
-
getShutdownExecutor
public java.util.concurrent.ExecutorService getShutdownExecutor()
-
setShutdownExecutor
public void setShutdownExecutor(java.util.concurrent.ExecutorService shutdownExecutor)
-
getHeartbeatExecutor
public java.util.concurrent.ScheduledExecutorService getHeartbeatExecutor()
-
setHeartbeatExecutor
public void setHeartbeatExecutor(java.util.concurrent.ScheduledExecutorService heartbeatExecutor)
-
setChannelRpcTimeout
public void setChannelRpcTimeout(int channelRpcTimeout)
-
setChannelShouldCheckRpcResponseType
public void setChannelShouldCheckRpcResponseType(boolean channelShouldCheckRpcResponseType)
-
setErrorOnWriteListener
public void setErrorOnWriteListener(ErrorOnWriteListener errorOnWriteListener)
-
getErrorOnWriteListener
public ErrorOnWriteListener getErrorOnWriteListener()
-
setWorkPoolTimeout
public void setWorkPoolTimeout(int workPoolTimeout)
-
getWorkPoolTimeout
public int getWorkPoolTimeout()
-
setTopologyRecoveryFilter
public void setTopologyRecoveryFilter(TopologyRecoveryFilter topologyRecoveryFilter)
-
getTopologyRecoveryFilter
public TopologyRecoveryFilter getTopologyRecoveryFilter()
-
setConnectionRecoveryTriggeringCondition
public void setConnectionRecoveryTriggeringCondition(java.util.function.Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition)
-
getConnectionRecoveryTriggeringCondition
public java.util.function.Predicate<ShutdownSignalException> getConnectionRecoveryTriggeringCondition()
-
setTopologyRecoveryRetryHandler
public void setTopologyRecoveryRetryHandler(RetryHandler topologyRecoveryRetryHandler)
-
getTopologyRecoveryRetryHandler
public RetryHandler getTopologyRecoveryRetryHandler()
-
setRecoveredQueueNameSupplier
public void setRecoveredQueueNameSupplier(RecoveredQueueNameSupplier recoveredQueueNameSupplier)
-
getRecoveredQueueNameSupplier
public RecoveredQueueNameSupplier getRecoveredQueueNameSupplier()
-
setTrafficListener
public void setTrafficListener(TrafficListener trafficListener)
-
getTrafficListener
public TrafficListener getTrafficListener()
-
setCredentialsRefreshService
public void setCredentialsRefreshService(CredentialsRefreshService credentialsRefreshService)
-
getCredentialsRefreshService
public CredentialsRefreshService getCredentialsRefreshService()
-
getMaxInboundMessageBodySize
public int getMaxInboundMessageBodySize()
-
setMaxInboundMessageBodySize
public void setMaxInboundMessageBodySize(int maxInboundMessageBodySize)
-
-