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

        public void setConnectionRecoveryTriggeringCondition​(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition)
      • setTopologyRecoveryRetryHandler

        public void setTopologyRecoveryRetryHandler​(RetryHandler topologyRecoveryRetryHandler)
      • getTopologyRecoveryRetryHandler

        public RetryHandler getTopologyRecoveryRetryHandler()
      • setRecoveredQueueNameSupplier

        public void setRecoveredQueueNameSupplier​(RecoveredQueueNameSupplier recoveredQueueNameSupplier)
      • setTrafficListener

        public void setTrafficListener​(TrafficListener trafficListener)
      • setCredentialsRefreshService

        public void setCredentialsRefreshService​(CredentialsRefreshService credentialsRefreshService)