com.rabbitmq.client.impl

Class ConnectionParams

java.lang.Object

com.rabbitmq.client.impl.ConnectionParams

public class ConnectionParams
extends Object

Constructor Summary

Constructors

Constructor and Description
ConnectionParams()

Method Summary

Modifier and Type	Method and Description
boolean	channelShouldCheckRpcResponseType()
int	getChannelRpcTimeout()
Map<String,Object>	getClientProperties()
Predicate<ShutdownSignalException>	getConnectionRecoveryTriggeringCondition()
ExecutorService	getConsumerWorkServiceExecutor()
CredentialsProvider	getCredentialsProvider()
CredentialsRefreshService	getCredentialsRefreshService()
ErrorOnWriteListener	getErrorOnWriteListener()
ExceptionHandler	getExceptionHandler()
int	getHandshakeTimeout()
ScheduledExecutorService	getHeartbeatExecutor()
long	getNetworkRecoveryInterval()
RecoveredQueueNameSupplier	getRecoveredQueueNameSupplier()
RecoveryDelayHandler	getRecoveryDelayHandler() Get the recovery delay handler.
int	getRequestedChannelMax()
int	getRequestedFrameMax()
int	getRequestedHeartbeat()
SaslConfig	getSaslConfig()
ExecutorService	getShutdownExecutor()
int	getShutdownTimeout()
ThreadFactory	getThreadFactory()
ExecutorService	getTopologyRecoveryExecutor() Get the topology recovery executor.
TopologyRecoveryFilter	getTopologyRecoveryFilter()
RetryHandler	getTopologyRecoveryRetryHandler()
TrafficListener	getTrafficListener()
String	getVirtualHost()
int	getWorkPoolTimeout()
boolean	isTopologyRecoveryEnabled()
void	setChannelRpcTimeout(int channelRpcTimeout)
void	setChannelShouldCheckRpcResponseType(boolean channelShouldCheckRpcResponseType)
void	setClientProperties(Map<String,Object> clientProperties)
void	setConnectionRecoveryTriggeringCondition(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition)
void	setConsumerWorkServiceExecutor(ExecutorService consumerWorkServiceExecutor)
void	setCredentialsProvider(CredentialsProvider credentialsProvider)
void	setCredentialsRefreshService(CredentialsRefreshService credentialsRefreshService)
void	setErrorOnWriteListener(ErrorOnWriteListener errorOnWriteListener)
void	setExceptionHandler(ExceptionHandler exceptionHandler)
void	setHandshakeTimeout(int timeout)
void	setHeartbeatExecutor(ScheduledExecutorService heartbeatExecutor)
void	setNetworkRecoveryInterval(long networkRecoveryInterval)
void	setRecoveredQueueNameSupplier(RecoveredQueueNameSupplier recoveredQueueNameSupplier)
void	setRecoveryDelayHandler(RecoveryDelayHandler recoveryDelayHandler)
void	setRequestedChannelMax(int requestedChannelMax)
void	setRequestedFrameMax(int requestedFrameMax)
void	setRequestedHeartbeat(int requestedHeartbeat)
void	setSaslConfig(SaslConfig saslConfig)
void	setShutdownExecutor(ExecutorService shutdownExecutor)
void	setShutdownTimeout(int shutdownTimeout)
void	setThreadFactory(ThreadFactory threadFactory)
void	setTopologyRecovery(boolean topologyRecovery)
void	setTopologyRecoveryExecutor(ExecutorService topologyRecoveryExecutor)
void	setTopologyRecoveryFilter(TopologyRecoveryFilter topologyRecoveryFilter)
void	setTopologyRecoveryRetryHandler(RetryHandler topologyRecoveryRetryHandler)
void	setTrafficListener(TrafficListener trafficListener)
void	setVirtualHost(String virtualHost)
void	setWorkPoolTimeout(int workPoolTimeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectionParams

public ConnectionParams()

Method Detail

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