Class ConnectionParams

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

public class ConnectionParams extends Object
  • 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()