Package | Description |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.message | |
org.apache.qpid.server.protocol.v0_10 | |
org.apache.qpid.transport |
Modifier and Type | Method and Description |
---|---|
Session |
XASessionImpl.createSession()
Create a qpid session.
|
protected Session |
AMQSession_0_10.createSession() |
protected Session |
XASessionImpl.getQpidSession()
Access to the underlying Qpid Session
|
protected Session |
AMQSession_0_10.getQpidSession()
Access to the underlying Qpid Session
|
Modifier and Type | Method and Description |
---|---|
void |
AMQSession_0_10.closed(Session ssn) |
void |
AMQSession_0_10.exception(Session ssn,
SessionException exc) |
void |
AMQSession_0_10.message(Session ssn,
MessageTransfer xfr) |
void |
AMQSession_0_10.opened(Session ssn) |
void |
AMQSession_0_10.resumed(Session ssn) |
Modifier and Type | Method and Description |
---|---|
static void |
AMQMessageDelegate_0_10.updateExchangeTypeMapping(Header header,
Session session)
Use the 0-10 ExchangeQuery call to validate the exchange type.
|
Modifier and Type | Class and Description |
---|---|
class |
ServerSession |
Modifier and Type | Method and Description |
---|---|
void |
ServerSessionDelegate.closed(Session session) |
void |
ServerSessionDelegate.command(Session session,
Method method) |
void |
ServerSessionDelegate.detached(Session session) |
void |
ServerSessionDelegate.dtxCommit(Session session,
DtxCommit method) |
void |
ServerSessionDelegate.dtxEnd(Session session,
DtxEnd method) |
void |
ServerSessionDelegate.dtxForget(Session session,
DtxForget method) |
void |
ServerSessionDelegate.dtxGetTimeout(Session session,
DtxGetTimeout method) |
void |
ServerSessionDelegate.dtxPrepare(Session session,
DtxPrepare method) |
void |
ServerSessionDelegate.dtxRecover(Session session,
DtxRecover method) |
void |
ServerSessionDelegate.dtxRollback(Session session,
DtxRollback method) |
void |
ServerSessionDelegate.dtxSelect(Session session,
DtxSelect method) |
void |
ServerSessionDelegate.dtxSetTimeout(Session session,
DtxSetTimeout method) |
void |
ServerSessionDelegate.dtxStart(Session session,
DtxStart method) |
void |
ServerSessionDelegate.exchangeBind(Session session,
ExchangeBind method) |
void |
ServerSessionDelegate.exchangeBound(Session session,
ExchangeBound method) |
void |
ServerSessionDelegate.exchangeDeclare(Session session,
ExchangeDeclare method) |
void |
ServerSessionDelegate.exchangeDelete(Session session,
ExchangeDelete method) |
void |
ServerSessionDelegate.exchangeQuery(Session session,
ExchangeQuery method) |
void |
ServerSessionDelegate.exchangeUnbind(Session session,
ExchangeUnbind method) |
void |
ServerSessionDelegate.executionSync(Session ssn,
ExecutionSync sync) |
void |
ServerSessionDelegate.messageAccept(Session session,
MessageAccept method) |
void |
ServerSessionDelegate.messageAcquire(Session session,
MessageAcquire method) |
void |
ServerSessionDelegate.messageCancel(Session session,
MessageCancel method) |
void |
ServerSessionDelegate.messageFlow(Session session,
MessageFlow flow) |
void |
ServerSessionDelegate.messageFlush(Session session,
MessageFlush method) |
void |
ServerSessionDelegate.messageReject(Session session,
MessageReject method) |
void |
ServerSessionDelegate.messageRelease(Session session,
MessageRelease method) |
void |
ServerSessionDelegate.messageResume(Session session,
MessageResume method) |
void |
ServerSessionDelegate.messageSetFlowMode(Session session,
MessageSetFlowMode sfm) |
void |
ServerSessionDelegate.messageStop(Session session,
MessageStop stop) |
void |
ServerSessionDelegate.messageSubscribe(Session session,
MessageSubscribe method) |
void |
ServerSessionDelegate.messageTransfer(Session ssn,
MessageTransfer xfr) |
void |
ServerSessionDelegate.queueDeclare(Session session,
QueueDeclare method) |
void |
ServerSessionDelegate.queueDelete(Session session,
QueueDelete method) |
void |
ServerSessionDelegate.queuePurge(Session session,
QueuePurge method) |
void |
ServerSessionDelegate.queueQuery(Session session,
QueueQuery method) |
void |
ServerConnection.registerSession(Session ssn) |
void |
ServerConnection.removeSession(Session ssn) |
void |
ServerSessionDelegate.txCommit(Session session,
TxCommit method) |
void |
ServerSessionDelegate.txRollback(Session session,
TxRollback method) |
void |
ServerSessionDelegate.txSelect(Session session,
TxSelect method) |
Modifier and Type | Method and Description |
---|---|
Session |
Connection.createSession() |
Session |
Connection.createSession(Binary name,
long expiry) |
Session |
Connection.createSession(Binary name,
long expiry,
boolean isNoReplay) |
Session |
Connection.createSession(byte[] name,
long expiry) |
Session |
Connection.createSession(long expiry) |
Session |
Connection.createSession(long expiry,
boolean isNoReplay) |
Session |
Connection.createSession(String name) |
Session |
Connection.createSession(String name,
long expiry) |
Session |
Connection.createSession(String name,
long expiry,
boolean isNoReplay) |
Session |
ServerDelegate.getSession(Connection conn,
SessionAttach atc) |
protected Session |
ServerDelegate.getSession(Connection conn,
SessionDelegate delegate,
SessionAttach atc) |
Session |
Connection.getSession(int channel) |
Session |
Connection.SessionFactory.newSession(Connection conn,
Binary name,
long expiry,
boolean isNoReplay) |
Modifier and Type | Method and Description |
---|---|
protected Collection<Session> |
Connection.getChannels() |
Modifier and Type | Method and Description |
---|---|
void |
SessionListener.closed(Session session) |
void |
SessionDelegate.closed(Session session) |
void |
SessionDelegate.command(Session ssn,
Method method) |
void |
SessionDelegate.command(Session ssn,
Method method,
boolean processed) |
void |
SessionDelegate.control(Session ssn,
Method method) |
void |
SessionDelegate.detached(Session session) |
void |
SessionDelegate.error(Session ssn,
ProtocolError error) |
void |
SessionListener.exception(Session session,
SessionException exception) |
void |
SessionDelegate.executionException(Session ssn,
ExecutionException exc) |
void |
SessionDelegate.executionResult(Session ssn,
ExecutionResult result) |
void |
SessionDelegate.executionSync(Session ssn,
ExecutionSync sync) |
void |
SessionDelegate.handle(Session ssn,
Method method) |
void |
SessionDelegate.init(Session ssn,
ProtocolHeader hdr) |
void |
SessionListener.message(Session ssn,
MessageTransfer xfr) |
void |
SessionDelegate.messageFlow(Session ssn,
MessageFlow flow) |
void |
SessionDelegate.messageSetFlowMode(Session ssn,
MessageSetFlowMode sfm) |
void |
SessionDelegate.messageStop(Session ssn,
MessageStop stop) |
void |
SessionDelegate.messageTransfer(Session ssn,
MessageTransfer xfr) |
void |
SessionListener.opened(Session session) |
void |
Connection.registerSession(Session ssn) |
void |
Connection.removeSession(Session ssn) |
void |
SessionListener.resumed(Session session) |
void |
SessionDelegate.sessionAttached(Session ssn,
SessionAttached atc) |
void |
SessionDelegate.sessionCommandPoint(Session ssn,
SessionCommandPoint scp) |
void |
SessionDelegate.sessionCompleted(Session ssn,
SessionCompleted cmp) |
void |
SessionDelegate.sessionFlush(Session ssn,
SessionFlush flush) |
void |
SessionDelegate.sessionKnownCompleted(Session ssn,
SessionKnownCompleted kcmp) |
void |
SessionDelegate.sessionRequestTimeout(Session ssn,
SessionRequestTimeout t) |
void |
SessionDelegate.sessionTimeout(Session ssn,
SessionTimeout t) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.