Package com.rabbitmq.client.impl

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

    • getMaxInboundMessageBodySize

      public int getMaxInboundMessageBodySize()

    • setMaxInboundMessageBodySize

      public void setMaxInboundMessageBodySize(int maxInboundMessageBodySize)