Modifier and Type | Method and Description |
---|---|
protected Connection |
AMQConnectionDelegate_0_10.getQpidConnection() |
protected Connection |
AMQSession_0_10.getQpidConnection() |
Modifier and Type | Method and Description |
---|---|
void |
AMQConnectionDelegate_0_10.closed(Connection conn) |
void |
AMQConnectionDelegate_0_10.exception(Connection conn,
ConnectionException exc) |
void |
AMQConnectionDelegate_0_10.opened(Connection conn) |
Constructor and Description |
---|
XASessionImpl(Connection qpidConnection,
AMQConnection con,
int channelId,
boolean transacted,
int ackMode,
int defaultPrefetchHigh,
int defaultPrefetchLow,
String name) |
XASessionImpl(Connection qpidConnection,
AMQConnection con,
int channelId,
int defaultPrefetchHigh,
int defaultPrefetchLow)
Create a JMS XASession
|
XASessionImpl(Connection qpidConnection,
AMQConnection con,
int channelId,
int ackMode,
int defaultPrefetchHigh,
int defaultPrefetchLow) |
Modifier and Type | Method and Description |
---|---|
void |
ClientConnectionDelegate.connectionHeartbeat(Connection conn,
ConnectionHeartbeat heartbeat) |
void |
ClientConnectionDelegate.connectionOpenOk(Connection conn,
ConnectionOpenOk ok) |
void |
ClientConnectionDelegate.writerIdle(Connection connection) |
Modifier and Type | Class and Description |
---|---|
class |
ServerConnection |
Modifier and Type | Method and Description |
---|---|
void |
ServerConnectionDelegate.connectionClose(Connection conn,
ConnectionClose close) |
void |
ServerConnectionDelegate.connectionOpen(Connection conn,
ConnectionOpen open) |
void |
ServerConnectionDelegate.connectionSecureOk(Connection conn,
ConnectionSecureOk ok) |
void |
ServerConnectionDelegate.connectionStartOk(Connection conn,
ConnectionStartOk ok) |
void |
ServerConnectionDelegate.connectionTuneOk(Connection conn,
ConnectionTuneOk ok) |
protected SaslServer |
ServerConnectionDelegate.createSaslServer(Connection conn,
String mechanism) |
ServerSession |
ServerConnectionDelegate.getSession(Connection conn,
SessionAttach atc) |
void |
ServerConnectionDelegate.init(Connection conn,
ProtocolHeader hdr) |
protected void |
ServerConnectionDelegate.secure(SaslServer ss,
Connection conn,
byte[] response) |
void |
ServerConnectionDelegate.sessionAttach(Connection conn,
SessionAttach atc) |
void |
ServerConnectionDelegate.sessionDetach(Connection conn,
SessionDetach dtc) |
Constructor and Description |
---|
ServerSession(Connection connection,
SessionDelegate delegate,
Binary name,
long expiry) |
Modifier and Type | Method and Description |
---|---|
Connection |
Session.getConnection() |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionListener.closed(Connection connection) |
void |
ConnectionDelegate.command(Connection conn,
Method method) |
protected void |
ServerDelegate.connectionAuthContinue(Connection conn,
byte[] challenge) |
protected void |
ServerDelegate.connectionAuthFailed(Connection conn,
Exception e) |
void |
ConnectionDelegate.connectionClose(Connection conn,
ConnectionClose close) |
void |
ConnectionDelegate.connectionCloseOk(Connection conn,
ConnectionCloseOk ok) |
void |
ConnectionDelegate.connectionHeartbeat(Connection conn,
ConnectionHeartbeat hearbeat) |
void |
ClientDelegate.connectionHeartbeat(Connection conn,
ConnectionHeartbeat hearbeat) |
void |
ServerDelegate.connectionOpen(Connection conn,
ConnectionOpen open) |
void |
ClientDelegate.connectionOpenOk(Connection conn,
ConnectionOpenOk ok) |
void |
ClientDelegate.connectionRedirect(Connection conn,
ConnectionRedirect redir) |
void |
ClientDelegate.connectionSecure(Connection conn,
ConnectionSecure secure) |
void |
ServerDelegate.connectionSecureOk(Connection conn,
ConnectionSecureOk ok) |
void |
ClientDelegate.connectionStart(Connection conn,
ConnectionStart start) |
void |
ServerDelegate.connectionStartOk(Connection conn,
ConnectionStartOk ok) |
void |
ClientDelegate.connectionTune(Connection conn,
ConnectionTune tune) |
void |
ServerDelegate.connectionTuneOk(Connection conn,
ConnectionTuneOk ok) |
void |
ConnectionDelegate.control(Connection conn,
Method method) |
protected SaslServer |
ServerDelegate.createSaslServer(Connection conn,
String mechanism) |
void |
ConnectionDelegate.error(Connection conn,
ProtocolError error) |
void |
ConnectionListener.exception(Connection connection,
ConnectionException exception) |
Session |
ServerDelegate.getSession(Connection conn,
SessionAttach atc) |
protected Session |
ServerDelegate.getSession(Connection conn,
SessionDelegate delegate,
SessionAttach atc) |
void |
ConnectionDelegate.handle(Connection conn,
Method method) |
void |
ServerDelegate.init(Connection conn,
ProtocolHeader hdr) |
void |
ClientDelegate.init(Connection conn,
ProtocolHeader hdr) |
Session |
Connection.SessionFactory.newSession(Connection conn,
Binary name,
long expiry,
boolean isNoReplay) |
void |
ConnectionListener.opened(Connection connection) |
protected void |
ServerDelegate.secure(Connection conn,
byte[] response) |
protected void |
ServerDelegate.secure(SaslServer ss,
Connection conn,
byte[] response) |
protected void |
ConnectionDelegate.sendConnectionCloseOkAndCloseSender(Connection conn) |
void |
ServerDelegate.sessionAttach(Connection conn,
SessionAttach atc) |
void |
ConnectionDelegate.sessionDetach(Connection conn,
SessionDetach dtc) |
void |
ConnectionDelegate.sessionDetached(Connection conn,
SessionDetached dtc) |
protected void |
ServerDelegate.setConnectionTuneOkChannelMax(Connection conn,
int okChannelMax) |
protected void |
ServerDelegate.tuneAuthorizedConnection(Connection conn) |
void |
ConnectionDelegate.writerIdle(Connection connection) |
Constructor and Description |
---|
Session(Connection connection,
Binary name,
long expiry) |
Session(Connection connection,
Binary name,
long expiry,
boolean noReplay) |
Session(Connection connection,
SessionDelegate delegate,
Binary name,
long expiry) |
Session(Connection connection,
SessionDelegate delegate,
Binary name,
long expiry,
boolean noReplay) |
Modifier and Type | Method and Description |
---|---|
void |
SASLEncryptor.closed(Connection conn) |
void |
SASLEncryptor.exception(Connection conn,
ConnectionException exception) |
void |
SASLEncryptor.opened(Connection conn) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.