Package com.rabbitmq.client.impl

Class ConnectionParams

  • public class ConnectionParams
extends Object

    • Constructor Detail

      • ConnectionParams

        public ConnectionParams()

    • Method Detail

      • getConsumerWorkServiceExecutor

        public ExecutorService getConsumerWorkServiceExecutor()

      • getVirtualHost

        public String getVirtualHost()

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

      • getNetworkRecoveryInterval

        public long 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.

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

      • setShutdownExecutor

        public void setShutdownExecutor​(ExecutorService shutdownExecutor)

      • setChannelRpcTimeout

        public void setChannelRpcTimeout​(int channelRpcTimeout)

      • setChannelShouldCheckRpcResponseType

        public void setChannelShouldCheckRpcResponseType​(boolean channelShouldCheckRpcResponseType)

      • setErrorOnWriteListener

        public void setErrorOnWriteListener​(ErrorOnWriteListener errorOnWriteListener)

      • setWorkPoolTimeout

        public void setWorkPoolTimeout​(int workPoolTimeout)

      • getWorkPoolTimeout

        public int getWorkPoolTimeout()

      • setTopologyRecoveryFilter

        public void setTopologyRecoveryFilter​(TopologyRecoveryFilter topologyRecoveryFilter)

      • setTopologyRecoveryRetryHandler

        public void setTopologyRecoveryRetryHandler​(RetryHandler topologyRecoveryRetryHandler)

      • getTopologyRecoveryRetryHandler

        public RetryHandler getTopologyRecoveryRetryHandler()

      • setTrafficListener

        public void setTrafficListener​(TrafficListener trafficListener)