All Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
void |
close() |
void |
close(Error error) |
boolean |
closedForInput() |
boolean |
closedForOutput() |
void |
closeSaslWithFailure() |
SessionEndpoint |
createSession(String name) |
int |
getChannelMax() |
ConnectionEventListener |
getConnectionEventListener() |
Container |
getContainer() |
AMQPDescribedTypeRegistry |
getDescribedTypeRegistry() |
long |
getDesiredIdleTimeout() |
long |
getIdleTimeout() |
String |
getLocalHostname() |
Object |
getLock() |
byte |
getMajorVersion() |
int |
getMaxFrameSize() |
byte |
getMinorVersion() |
SocketAddress |
getRemoteAddress() |
String |
getRemoteContainerId() |
Error |
getRemoteError() |
String |
getRemoteHostname() |
Map |
getRemoteProperties() |
byte |
getRevision() |
long |
getSyncTimeout() |
Principal |
getUser() |
void |
handleError(Error error) |
void |
initiateSASL(String[] mechanismNames) |
void |
inputClosed() |
void |
invalidHeaderReceived() |
boolean |
isAuthenticated() |
boolean |
isClosed() |
boolean |
isOpen() |
boolean |
isSASLComplete() |
void |
open() |
void |
protocolHeaderReceived(byte major,
byte minorVersion,
byte revision) |
void |
receive(short channel,
Object frame) |
void |
receiveAttach(short channel,
Attach attach) |
void |
receiveBegin(short channel,
Begin begin) |
void |
receiveClose(short channel,
Close close) |
void |
receiveDetach(short channel,
Detach detach) |
void |
receiveDisposition(short channel,
Disposition disposition) |
void |
receiveEnd(short channel,
End end) |
void |
receiveFlow(short channel,
Flow flow) |
void |
receiveOpen(short channel,
Open open) |
void |
receiveSaslChallenge(SaslChallenge saslChallenge) |
void |
receiveSaslInit(SaslInit saslInit) |
void |
receiveSaslMechanisms(SaslMechanisms saslMechanisms) |
void |
receiveSaslOutcome(SaslOutcome saslOutcome) |
void |
receiveSaslResponse(SaslResponse saslResponse) |
void |
receiveTransfer(short channel,
Transfer transfer) |
boolean |
requiresSASL() |
void |
send(short channel,
FrameBody body) |
int |
send(short channel,
FrameBody body,
QpidByteBuffer payload) |
void |
sendEnd(short channel,
End end,
boolean remove) |
void |
setChannelMax(short channelMax) |
void |
setClosedForOutput(boolean closed) |
void |
setConnectionEventListener(ConnectionEventListener connectionEventListener) |
void |
setDesiredIdleTimeout(long desiredIdleTimeout) |
void |
setExternalPrincipal(Principal externalPrincipal) |
void |
setFrameOutputHandler(FrameOutputHandler<FrameBody> frameOutputHandler) |
void |
setLogger(ConnectionEndpoint.FrameReceiptLogger logger) |
void |
setOnSaslComplete(Runnable task) |
void |
setPrincipal(Principal user) |
void |
setProperties(Map<Symbol,Object> properties) |
void |
setRemoteAddress(SocketAddress remoteAddress) |
void |
setRemoteHostname(String remoteHostname) |
void |
setSaslFrameOutput(FrameOutputHandler<SaslFrameBody> saslFrameOutput) |
void |
setSyncTimeout(long syncTimeout) |
void |
waitUntil(Predicate predicate) |
void |
waitUntil(Predicate predicate,
long timeout) |