org.apache.qpid
Class ToyBroker
java.lang.Object
org.apache.qpid.transport.MethodDelegate<Session>
org.apache.qpid.transport.SessionDelegate
org.apache.qpid.ToyBroker
- All Implemented Interfaces:
- ProtocolDelegate<Session>
class ToyBroker
- extends SessionDelegate
ToyBroker
Methods inherited from class org.apache.qpid.transport.SessionDelegate |
closed, command, control, detached, error, executionException, executionResult, executionSync, handle, init, messageSetFlowMode, messageStop, 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, exchangeBound, exchangeDeclare, exchangeDelete, exchangeQuery, exchangeUnbind, messageAccept, messageCancel, messageReject, messageRelease, messageResume, queueDelete, queuePurge, sessionAttach, sessionConfirmed, sessionDetach, sessionDetached, sessionExpected, sessionGap, txCommit, txRollback, txSelect |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ToyBroker
public ToyBroker(ToyExchange exchange)
messageAcquire
public void messageAcquire(Session context,
MessageAcquire struct)
- Overrides:
messageAcquire
in class MethodDelegate<Session>
queueDeclare
public void queueDeclare(Session ssn,
QueueDeclare qd)
- Overrides:
queueDeclare
in class MethodDelegate<Session>
exchangeBind
public void exchangeBind(Session ssn,
ExchangeBind qb)
- Overrides:
exchangeBind
in class MethodDelegate<Session>
queueQuery
public void queueQuery(Session ssn,
QueueQuery qq)
- Overrides:
queueQuery
in class MethodDelegate<Session>
messageSubscribe
public void messageSubscribe(Session ssn,
MessageSubscribe ms)
- Overrides:
messageSubscribe
in class MethodDelegate<Session>
messageFlow
public void messageFlow(Session ssn,
MessageFlow struct)
- Overrides:
messageFlow
in class SessionDelegate
messageFlush
public void messageFlush(Session ssn,
MessageFlush struct)
- Overrides:
messageFlush
in class MethodDelegate<Session>
messageTransfer
public void messageTransfer(Session ssn,
MessageTransfer xfr)
- Overrides:
messageTransfer
in class SessionDelegate
main
public static final void main(String[] args)
throws IOException
- Throws:
IOException
Licensed to the Apache Software Foundation