All Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
void |
addConnectionListener(ConnectionListener listener) |
void |
addFrameSizeObserver(FrameSizeObserver frameSizeObserver) |
void |
close() |
void |
close(ConnectionCloseCode replyCode,
String replyText,
Option... _options) |
void |
closeCode(ConnectionClose close) |
void |
closed() |
void |
connect(ConnectionSettings settings) |
void |
connect(String host,
int port,
String vhost,
String username,
String password,
boolean ssl,
String saslMechs) |
void |
connect(String host,
int port,
String vhost,
String username,
String password,
boolean ssl,
String saslMechs,
Map<String,Object> clientProps) |
Session |
createSession() |
Session |
createSession(Binary name,
long expiry) |
Session |
createSession(Binary name,
long expiry,
boolean isNoReplay) |
Session |
createSession(byte[] name,
long expiry) |
Session |
createSession(long expiry) |
Session |
createSession(long expiry,
boolean isNoReplay) |
Session |
createSession(String name) |
Session |
createSession(String name,
long expiry) |
Session |
createSession(String name,
long expiry,
boolean isNoReplay) |
void |
dispatch(Method method) |
protected void |
doHeartBeat() |
void |
exception(ConnectionException e) |
void |
exception(Throwable t) |
void |
flush() |
int |
getChannelMax() |
protected Collection<Session> |
getChannels() |
ConnectionDelegate |
getConnectionDelegate() |
ConnectionSettings |
getConnectionSettings() |
List<ConnectionListener> |
getListeners() |
SocketAddress |
getLocalAddress() |
NetworkConnection |
getNetworkConnection() |
SocketAddress |
getRemoteSocketAddress() |
SaslClient |
getSaslClient() |
SecurityLayer |
getSecurityLayer() |
ProtocolEventSender |
getSender() |
Map<String,Object> |
getServerProperties() |
Session |
getSession(int channel) |
String |
getUserID() |
boolean |
hasSessionWithName(byte[] name) |
protected void |
invoke(Method method) |
boolean |
isClosing() |
protected boolean |
isConnectionLost() |
boolean |
isConnectionResuming() |
boolean |
isMessageCompressionSupported() |
boolean |
isRedirecting() |
boolean |
isVirtualHostPropertiesSupported() |
void |
notifyFailoverRequired() |
void |
received(ProtocolEvent event) |
void |
registerSession(Session ssn) |
void |
removeSession(Session ssn) |
void |
resume() |
void |
send(ProtocolEvent event) |
protected void |
sendConnectionClose(ConnectionCloseCode replyCode,
String replyText,
Option... _options) |
void |
setConnectionDelegate(ConnectionDelegate delegate) |
protected void |
setLocalAddress(SocketAddress localAddress) |
void |
setMaxFrameSize(int maxFrameSize) |
void |
setNetworkConnection(NetworkConnection network) |
void |
setRedirecting(boolean redirecting) |
protected void |
setRemoteAddress(SocketAddress remoteAddress) |
void |
setSender(ProtocolEventSender sender) |
void |
setServerProperties(Map<String,Object> serverProperties) |
void |
setSessionFactory(Connection.SessionFactory sessionFactory) |
protected void |
setState(Connection.State state) |
void |
setUserID(String id) |
String |
toString() |