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() |
int |
getHandshakeTimeout() |
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() |
void |
setHandshakeTimeout(int timeout) |
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
- factory that instantiates threads used by the clientexceptionHandler
- handles unhandled consumer exceptionspublic 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 getHandshakeTimeout()
public void setHandshakeTimeout(int timeout)
public int getShutdownTimeout()
public SaslConfig getSaslConfig()
public ExceptionHandler getExceptionHandler()
public long getNetworkRecoveryInterval()
public boolean isTopologyRecoveryEnabled()
public java.util.concurrent.ThreadFactory getThreadFactory()