Class ConnectionParams

java.lang.Object
com.rabbitmq.client.impl.ConnectionParams

public class ConnectionParams extends Object
  • Field Details

    • credentialsProvider

      private CredentialsProvider credentialsProvider
    • consumerWorkServiceExecutor

      private ExecutorService consumerWorkServiceExecutor
    • heartbeatExecutor

      private ScheduledExecutorService heartbeatExecutor
    • shutdownExecutor

      private ExecutorService shutdownExecutor
    • virtualHost

      private String virtualHost
    • clientProperties

      private Map<String,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 ExecutorService topologyRecoveryExecutor
    • channelRpcTimeout

      private int channelRpcTimeout
    • channelShouldCheckRpcResponseType

      private boolean channelShouldCheckRpcResponseType
    • errorOnWriteListener

      private ErrorOnWriteListener errorOnWriteListener
    • workPoolTimeout

      private int workPoolTimeout
    • topologyRecoveryFilter

      private TopologyRecoveryFilter topologyRecoveryFilter
    • connectionRecoveryTriggeringCondition

      private Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition
    • topologyRecoveryRetryHandler

      private RetryHandler topologyRecoveryRetryHandler
    • recoveredQueueNameSupplier

      private RecoveredQueueNameSupplier recoveredQueueNameSupplier
    • exceptionHandler

      private ExceptionHandler exceptionHandler
    • threadFactory

      private ThreadFactory threadFactory
    • trafficListener

      private TrafficListener trafficListener
    • credentialsRefreshService

      private CredentialsRefreshService credentialsRefreshService
    • maxInboundMessageBodySize

      private int maxInboundMessageBodySize
  • Constructor Details

    • ConnectionParams

      public ConnectionParams()
  • Method Details

    • getCredentialsProvider

      public CredentialsProvider getCredentialsProvider()
    • getConsumerWorkServiceExecutor

      public ExecutorService getConsumerWorkServiceExecutor()
    • getVirtualHost

      public String getVirtualHost()
    • getClientProperties

      public Map<String,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 of getNetworkRecoveryInterval().
    • isTopologyRecoveryEnabled

      public boolean isTopologyRecoveryEnabled()
    • getTopologyRecoveryExecutor

      public ExecutorService getTopologyRecoveryExecutor()
      Get the topology recovery executor. If null, the main connection thread should be used.
      Returns:
      executor. May be null.
    • getThreadFactory

      public ThreadFactory getThreadFactory()
    • getChannelRpcTimeout

      public int getChannelRpcTimeout()
    • channelShouldCheckRpcResponseType

      public boolean channelShouldCheckRpcResponseType()
    • setCredentialsProvider

      public void setCredentialsProvider(CredentialsProvider credentialsProvider)
    • setConsumerWorkServiceExecutor

      public void setConsumerWorkServiceExecutor(ExecutorService consumerWorkServiceExecutor)
    • setVirtualHost

      public void setVirtualHost(String virtualHost)
    • setClientProperties

      public void setClientProperties(Map<String,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(ExecutorService topologyRecoveryExecutor)
    • setExceptionHandler

      public void setExceptionHandler(ExceptionHandler exceptionHandler)
    • setThreadFactory

      public void setThreadFactory(ThreadFactory threadFactory)
    • getShutdownExecutor

      public ExecutorService getShutdownExecutor()
    • setShutdownExecutor

      public void setShutdownExecutor(ExecutorService shutdownExecutor)
    • getHeartbeatExecutor

      public ScheduledExecutorService getHeartbeatExecutor()
    • setHeartbeatExecutor

      public void setHeartbeatExecutor(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(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition)
    • getConnectionRecoveryTriggeringCondition

      public 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)