org.apache.qpid
Class ToyBroker

java.lang.Object
  extended by org.apache.qpid.transport.MethodDelegate<Session>
      extended by org.apache.qpid.transport.SessionDelegate
          extended by org.apache.qpid.ToyBroker
All Implemented Interfaces:
ProtocolDelegate<Session>

 class ToyBroker
extends SessionDelegate

ToyBroker


Field Summary
 
Fields inherited from class org.apache.qpid.transport.SessionDelegate
log
 
Constructor Summary
ToyBroker(ToyExchange exchange)
           
 
Method Summary
 void exchangeBind(Session ssn, ExchangeBind qb)
           
static void main(String[] args)
           
 void messageAcquire(Session context, MessageAcquire struct)
           
 void messageFlow(Session ssn, MessageFlow struct)
           
 void messageFlush(Session ssn, MessageFlush struct)
           
 void messageSubscribe(Session ssn, MessageSubscribe ms)
           
 void messageTransfer(Session ssn, MessageTransfer xfr)
           
 void queueDeclare(Session ssn, QueueDeclare qd)
           
 void queueQuery(Session ssn, QueueQuery qq)
           
 
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
 

Constructor Detail

ToyBroker

public ToyBroker(ToyExchange exchange)
Method Detail

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