Class ConnectionParams


  • public class ConnectionParams
    extends java.lang.Object
    • Field Detail

      • consumerWorkServiceExecutor

        private java.util.concurrent.ExecutorService consumerWorkServiceExecutor
      • heartbeatExecutor

        private java.util.concurrent.ScheduledExecutorService heartbeatExecutor
      • shutdownExecutor

        private java.util.concurrent.ExecutorService shutdownExecutor
      • virtualHost

        private java.lang.String virtualHost
      • clientProperties

        private java.util.Map<java.lang.String,​java.lang.Object> clientProperties
      • requestedFrameMax

        private int requestedFrameMax
      • requestedChannelMax

        private int requestedChannelMax
      • requestedHeartbeat

        private int requestedHeartbeat
      • handshakeTimeout

        private int handshakeTimeout
      • shutdownTimeout

        private int shutdownTimeout
      • networkRecoveryInterval

        private long networkRecoveryInterval
      • topologyRecovery

        private boolean topologyRecovery
      • topologyRecoveryExecutor

        private java.util.concurrent.ExecutorService topologyRecoveryExecutor
      • channelRpcTimeout

        private int channelRpcTimeout
      • channelShouldCheckRpcResponseType

        private boolean channelShouldCheckRpcResponseType
      • workPoolTimeout

        private int workPoolTimeout
      • connectionRecoveryTriggeringCondition

        private java.util.function.Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition
      • topologyRecoveryRetryHandler

        private RetryHandler topologyRecoveryRetryHandler
      • threadFactory

        private java.util.concurrent.ThreadFactory threadFactory
      • maxInboundMessageBodySize

        private int maxInboundMessageBodySize
    • Constructor Detail

      • ConnectionParams

        public ConnectionParams()
    • Method Detail

      • getConsumerWorkServiceExecutor

        public java.util.concurrent.ExecutorService getConsumerWorkServiceExecutor()
      • getVirtualHost

        public java.lang.String getVirtualHost()
      • getClientProperties

        public java.util.Map<java.lang.String,​java.lang.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()
      • getNetworkRecoveryInterval

        public long getNetworkRecoveryInterval()
      • isTopologyRecoveryEnabled

        public boolean isTopologyRecoveryEnabled()
      • getTopologyRecoveryExecutor

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

        public java.util.concurrent.ThreadFactory getThreadFactory()
      • getChannelRpcTimeout

        public int getChannelRpcTimeout()
      • channelShouldCheckRpcResponseType

        public boolean channelShouldCheckRpcResponseType()
      • setCredentialsProvider

        public void setCredentialsProvider​(CredentialsProvider credentialsProvider)
      • setConsumerWorkServiceExecutor

        public void setConsumerWorkServiceExecutor​(java.util.concurrent.ExecutorService consumerWorkServiceExecutor)
      • setVirtualHost

        public void setVirtualHost​(java.lang.String virtualHost)
      • setClientProperties

        public void setClientProperties​(java.util.Map<java.lang.String,​java.lang.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​(java.util.concurrent.ExecutorService topologyRecoveryExecutor)
      • setExceptionHandler

        public void setExceptionHandler​(ExceptionHandler exceptionHandler)
      • setThreadFactory

        public void setThreadFactory​(java.util.concurrent.ThreadFactory threadFactory)
      • getShutdownExecutor

        public java.util.concurrent.ExecutorService getShutdownExecutor()
      • setShutdownExecutor

        public void setShutdownExecutor​(java.util.concurrent.ExecutorService shutdownExecutor)
      • getHeartbeatExecutor

        public java.util.concurrent.ScheduledExecutorService getHeartbeatExecutor()
      • setHeartbeatExecutor

        public void setHeartbeatExecutor​(java.util.concurrent.ScheduledExecutorService heartbeatExecutor)
      • 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​(java.util.function.Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition)
      • getConnectionRecoveryTriggeringCondition

        public java.util.function.Predicate<ShutdownSignalException> getConnectionRecoveryTriggeringCondition()
      • 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)
      • getMaxInboundMessageBodySize

        public int getMaxInboundMessageBodySize()
      • setMaxInboundMessageBodySize

        public void setMaxInboundMessageBodySize​(int maxInboundMessageBodySize)