public class ConnectionParams
extends java.lang.Object
Constructor and Description |
---|
ConnectionParams(java.lang.String username,
java.lang.String password,
java.util.concurrent.ExecutorService executor,
java.lang.String virtualHost,
java.util.Map<java.lang.String,java.lang.Object> clientProperties,
int requestedFrameMax,
int requestedChannelMax,
int requestedHeartbeat,
int shutdownTimeout,
SaslConfig saslConfig,
long networkRecoveryInterval,
boolean topologyRecovery,
ExceptionHandler exceptionHandler,
java.util.concurrent.ThreadFactory threadFactory) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.lang.Object> |
getClientProperties() |
ExceptionHandler |
getExceptionHandler() |
java.util.concurrent.ExecutorService |
getExecutor() |
long |
getNetworkRecoveryInterval() |
java.lang.String |
getPassword() |
int |
getRequestedChannelMax() |
int |
getRequestedFrameMax() |
int |
getRequestedHeartbeat() |
SaslConfig |
getSaslConfig() |
int |
getShutdownTimeout() |
java.util.concurrent.ThreadFactory |
getThreadFactory() |
java.lang.String |
getUsername() |
java.lang.String |
getVirtualHost() |
boolean |
isTopologyRecoveryEnabled() |
public ConnectionParams(java.lang.String username, java.lang.String password, java.util.concurrent.ExecutorService executor, java.lang.String virtualHost, java.util.Map<java.lang.String,java.lang.Object> clientProperties, int requestedFrameMax, int requestedChannelMax, int requestedHeartbeat, int shutdownTimeout, SaslConfig saslConfig, long networkRecoveryInterval, boolean topologyRecovery, ExceptionHandler exceptionHandler, java.util.concurrent.ThreadFactory threadFactory)
username
- name used to establish connectionpassword
- for username
executor
- thread pool service for consumer threads for channels on this connectionvirtualHost
- virtual host of this connectionclientProperties
- client info used in negotiating with the serverrequestedFrameMax
- max size of frame offeredrequestedChannelMax
- max number of channels offeredrequestedHeartbeat
- heart-beat in seconds offeredsaslConfig
- sasl configuration hooknetworkRecoveryInterval
- interval used when recovering from network failuretopologyRecovery
- should topology (queues, exchanges, bindings, consumers) recovery be performed?threadFactory
- exceptionHandler
- public java.lang.String getUsername()
public java.lang.String getPassword()
public java.util.concurrent.ExecutorService getExecutor()
public java.lang.String getVirtualHost()
public java.util.Map<java.lang.String,java.lang.Object> getClientProperties()
public int getRequestedFrameMax()
public int getRequestedChannelMax()
public int getRequestedHeartbeat()
public int getShutdownTimeout()
public SaslConfig getSaslConfig()
public ExceptionHandler getExceptionHandler()
public long getNetworkRecoveryInterval()
public boolean isTopologyRecoveryEnabled()
public java.util.concurrent.ThreadFactory getThreadFactory()