org.apache.qpid.server.transport
Class ServerSessionDelegate
java.lang.Object
org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
org.apache.qpid.transport.SessionDelegate
org.apache.qpid.server.transport.ServerSessionDelegate
- All Implemented Interfaces:
- org.apache.qpid.transport.ProtocolDelegate<org.apache.qpid.transport.Session>
public class ServerSessionDelegate
- extends org.apache.qpid.transport.SessionDelegate
Fields inherited from class org.apache.qpid.transport.SessionDelegate |
log |
Method Summary |
void |
closed(org.apache.qpid.transport.Session session)
|
void |
command(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.Method method)
|
protected AMQQueue |
createQueue(String queueName,
org.apache.qpid.transport.QueueDeclare body,
VirtualHost virtualHost,
ServerSession session)
|
void |
detached(org.apache.qpid.transport.Session session)
|
void |
exchangeBind(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeBind method)
|
void |
exchangeBound(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeBound method)
|
void |
exchangeDeclare(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeDeclare method)
|
void |
exchangeDelete(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeDelete method)
|
void |
exchangeQuery(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeQuery method)
|
void |
exchangeUnbind(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeUnbind method)
|
Collection<Subscription_0_10> |
getSubscriptions(org.apache.qpid.transport.Session session)
|
void |
messageAccept(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageAccept method)
|
void |
messageAcquire(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageAcquire method)
|
void |
messageCancel(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageCancel method)
|
void |
messageFlow(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageFlow flow)
|
void |
messageFlush(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageFlush method)
|
void |
messageReject(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageReject method)
|
void |
messageRelease(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageRelease method)
|
void |
messageResume(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageResume method)
|
void |
messageSetFlowMode(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageSetFlowMode sfm)
|
void |
messageStop(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageStop stop)
|
void |
messageSubscribe(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageSubscribe method)
|
void |
messageTransfer(org.apache.qpid.transport.Session ssn,
org.apache.qpid.transport.MessageTransfer xfr)
|
void |
queueDeclare(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.QueueDeclare method)
|
void |
queueDelete(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.QueueDelete method)
|
void |
queuePurge(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.QueuePurge method)
|
void |
queueQuery(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.QueueQuery method)
|
void |
txCommit(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.TxCommit method)
|
void |
txRollback(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.TxRollback method)
|
void |
txSelect(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.TxSelect method)
|
Methods inherited from class org.apache.qpid.transport.SessionDelegate |
control, error, executionException, executionResult, executionSync, handle, init, sessionAttached, sessionCommandPoint, sessionCompleted, sessionFlush, sessionKnownCompleted, sessionRequestTimeout, sessionTimeout |
Methods inherited from class org.apache.qpid.transport.MethodDelegate |
connectionClose, connectionCloseOk, connectionHeartbeat, connectionOpen, connectionOpenOk, connectionRedirect, connectionSecure, connectionSecureOk, connectionStart, connectionStartOk, connectionTune, connectionTuneOk, dtxCommit, dtxEnd, dtxForget, dtxGetTimeout, dtxPrepare, dtxRecover, dtxRollback, dtxSelect, dtxSetTimeout, dtxStart, sessionAttach, sessionConfirmed, sessionDetach, sessionDetached, sessionExpected, sessionGap |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ServerSessionDelegate
public ServerSessionDelegate(IApplicationRegistry appRegistry)
command
public void command(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.Method method)
- Specified by:
command
in interface org.apache.qpid.transport.ProtocolDelegate<org.apache.qpid.transport.Session>
- Overrides:
command
in class org.apache.qpid.transport.SessionDelegate
messageAccept
public void messageAccept(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageAccept method)
- Overrides:
messageAccept
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
messageReject
public void messageReject(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageReject method)
- Overrides:
messageReject
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
messageRelease
public void messageRelease(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageRelease method)
- Overrides:
messageRelease
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
messageAcquire
public void messageAcquire(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageAcquire method)
- Overrides:
messageAcquire
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
messageResume
public void messageResume(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageResume method)
- Overrides:
messageResume
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
messageSubscribe
public void messageSubscribe(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageSubscribe method)
- Overrides:
messageSubscribe
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
messageTransfer
public void messageTransfer(org.apache.qpid.transport.Session ssn,
org.apache.qpid.transport.MessageTransfer xfr)
- Overrides:
messageTransfer
in class org.apache.qpid.transport.SessionDelegate
messageCancel
public void messageCancel(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageCancel method)
- Overrides:
messageCancel
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
messageFlush
public void messageFlush(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageFlush method)
- Overrides:
messageFlush
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
txSelect
public void txSelect(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.TxSelect method)
- Overrides:
txSelect
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
txCommit
public void txCommit(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.TxCommit method)
- Overrides:
txCommit
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
txRollback
public void txRollback(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.TxRollback method)
- Overrides:
txRollback
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
exchangeDeclare
public void exchangeDeclare(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeDeclare method)
- Overrides:
exchangeDeclare
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
exchangeDelete
public void exchangeDelete(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeDelete method)
- Overrides:
exchangeDelete
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
exchangeQuery
public void exchangeQuery(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeQuery method)
- Overrides:
exchangeQuery
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
exchangeBind
public void exchangeBind(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeBind method)
- Overrides:
exchangeBind
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
exchangeUnbind
public void exchangeUnbind(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeUnbind method)
- Overrides:
exchangeUnbind
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
exchangeBound
public void exchangeBound(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.ExchangeBound method)
- Overrides:
exchangeBound
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
queueDeclare
public void queueDeclare(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.QueueDeclare method)
- Overrides:
queueDeclare
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
createQueue
protected AMQQueue createQueue(String queueName,
org.apache.qpid.transport.QueueDeclare body,
VirtualHost virtualHost,
ServerSession session)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
queueDelete
public void queueDelete(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.QueueDelete method)
- Overrides:
queueDelete
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
queuePurge
public void queuePurge(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.QueuePurge method)
- Overrides:
queuePurge
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
queueQuery
public void queueQuery(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.QueueQuery method)
- Overrides:
queueQuery
in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
messageSetFlowMode
public void messageSetFlowMode(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageSetFlowMode sfm)
- Overrides:
messageSetFlowMode
in class org.apache.qpid.transport.SessionDelegate
messageStop
public void messageStop(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageStop stop)
- Overrides:
messageStop
in class org.apache.qpid.transport.SessionDelegate
messageFlow
public void messageFlow(org.apache.qpid.transport.Session session,
org.apache.qpid.transport.MessageFlow flow)
- Overrides:
messageFlow
in class org.apache.qpid.transport.SessionDelegate
closed
public void closed(org.apache.qpid.transport.Session session)
- Overrides:
closed
in class org.apache.qpid.transport.SessionDelegate
detached
public void detached(org.apache.qpid.transport.Session session)
- Overrides:
detached
in class org.apache.qpid.transport.SessionDelegate
getSubscriptions
public Collection<Subscription_0_10> getSubscriptions(org.apache.qpid.transport.Session session)
Licensed to the Apache Software Foundation