org.apache.qpid.transport
Class SessionInvoker

java.lang.Object
  extended by org.apache.qpid.transport.SessionInvoker
Direct Known Subclasses:
Session

public abstract class SessionInvoker
extends Object


Constructor Summary
SessionInvoker()
           
 
Method Summary
 Future<XaResult> dtxCommit(Xid xid, Option... _options)
           
 Future<XaResult> dtxEnd(Xid xid, Option... _options)
           
 void dtxForget(Xid xid, Option... _options)
           
 Future<GetTimeoutResult> dtxGetTimeout(Xid xid, Option... _options)
           
 Future<XaResult> dtxPrepare(Xid xid, Option... _options)
           
 Future<RecoverResult> dtxRecover(Option... _options)
           
 Future<XaResult> dtxRollback(Xid xid, Option... _options)
           
 void dtxSelect(Option... _options)
           
 void dtxSetTimeout(Xid xid, long timeout, Option... _options)
           
 Future<XaResult> dtxStart(Xid xid, Option... _options)
           
 void exchangeBind(String queue, String exchange, String bindingKey, Map<String,Object> arguments, Option... _options)
           
 Future<ExchangeBoundResult> exchangeBound(String exchange, String queue, String bindingKey, Map<String,Object> arguments, Option... _options)
           
 void exchangeDeclare(String exchange, String type, String alternateExchange, Map<String,Object> arguments, Option... _options)
           
 void exchangeDelete(String exchange, Option... _options)
           
 Future<ExchangeQueryResult> exchangeQuery(String name, Option... _options)
           
 void exchangeUnbind(String queue, String exchange, String bindingKey, Option... _options)
           
 void executionException(ExecutionErrorCode errorCode, int commandId, short classCode, short commandCode, short fieldIndex, String description, Map<String,Object> errorInfo, Option... _options)
           
 void executionResult(int commandId, Struct value, Option... _options)
           
 void executionSync(Option... _options)
           
protected abstract  void invoke(Method method)
           
protected abstract
<T> Future<T>
invoke(Method method, Class<T> resultClass)
           
 void messageAccept(RangeSet transfers, Option... _options)
           
 Future<Acquired> messageAcquire(RangeSet transfers, Option... _options)
           
 void messageCancel(String destination, Option... _options)
           
 void messageFlow(String destination, MessageCreditUnit unit, long value, Option... _options)
           
 void messageFlush(String destination, Option... _options)
           
 void messageReject(RangeSet transfers, MessageRejectCode code, String text, Option... _options)
           
 void messageRelease(RangeSet transfers, Option... _options)
           
 Future<MessageResumeResult> messageResume(String destination, String resumeId, Option... _options)
           
 void messageSetFlowMode(String destination, MessageFlowMode flowMode, Option... _options)
           
 void messageStop(String destination, Option... _options)
           
 void messageSubscribe(String queue, String destination, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, String resumeId, long resumeTtl, Map<String,Object> arguments, Option... _options)
           
 void messageTransfer(String destination, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, Header header, ByteBuffer body, Option... _options)
           
 void queueDeclare(String queue, String alternateExchange, Map<String,Object> arguments, Option... _options)
           
 void queueDelete(String queue, Option... _options)
           
 void queuePurge(String queue, Option... _options)
           
 Future<QueueQueryResult> queueQuery(String queue, Option... _options)
           
(package private)  void sessionAttach(byte[] name, Option... _options)
           
(package private)  void sessionAttached(byte[] name, Option... _options)
           
(package private)  void sessionCommandPoint(int commandId, long commandOffset, Option... _options)
           
(package private)  void sessionCompleted(RangeSet commands, Option... _options)
           
(package private)  void sessionConfirmed(RangeSet commands, List<Object> fragments, Option... _options)
           
(package private)  void sessionDetach(byte[] name, Option... _options)
           
(package private)  void sessionDetached(byte[] name, SessionDetachCode code, Option... _options)
           
(package private)  void sessionExpected(RangeSet commands, List<Object> fragments, Option... _options)
           
(package private)  void sessionFlush(Option... _options)
           
(package private)  void sessionGap(RangeSet commands, Option... _options)
           
(package private)  void sessionKnownCompleted(RangeSet commands, Option... _options)
           
(package private)  void sessionRequestTimeout(long timeout, Option... _options)
           
(package private)  void sessionTimeout(long timeout, Option... _options)
           
 void txCommit(Option... _options)
           
 void txRollback(Option... _options)
           
 void txSelect(Option... _options)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SessionInvoker

public SessionInvoker()
Method Detail

sessionAttach

final void sessionAttach(byte[] name,
                         Option... _options)

sessionAttached

final void sessionAttached(byte[] name,
                           Option... _options)

sessionDetach

final void sessionDetach(byte[] name,
                         Option... _options)

sessionDetached

final void sessionDetached(byte[] name,
                           SessionDetachCode code,
                           Option... _options)

sessionRequestTimeout

final void sessionRequestTimeout(long timeout,
                                 Option... _options)

sessionTimeout

final void sessionTimeout(long timeout,
                          Option... _options)

sessionCommandPoint

final void sessionCommandPoint(int commandId,
                               long commandOffset,
                               Option... _options)

sessionExpected

final void sessionExpected(RangeSet commands,
                           List<Object> fragments,
                           Option... _options)

sessionConfirmed

final void sessionConfirmed(RangeSet commands,
                            List<Object> fragments,
                            Option... _options)

sessionCompleted

final void sessionCompleted(RangeSet commands,
                            Option... _options)

sessionKnownCompleted

final void sessionKnownCompleted(RangeSet commands,
                                 Option... _options)

sessionFlush

final void sessionFlush(Option... _options)

sessionGap

final void sessionGap(RangeSet commands,
                      Option... _options)

executionSync

public final void executionSync(Option... _options)

executionResult

public final void executionResult(int commandId,
                                  Struct value,
                                  Option... _options)

executionException

public final void executionException(ExecutionErrorCode errorCode,
                                     int commandId,
                                     short classCode,
                                     short commandCode,
                                     short fieldIndex,
                                     String description,
                                     Map<String,Object> errorInfo,
                                     Option... _options)

messageTransfer

public final void messageTransfer(String destination,
                                  MessageAcceptMode acceptMode,
                                  MessageAcquireMode acquireMode,
                                  Header header,
                                  ByteBuffer body,
                                  Option... _options)

messageAccept

public final void messageAccept(RangeSet transfers,
                                Option... _options)

messageReject

public final void messageReject(RangeSet transfers,
                                MessageRejectCode code,
                                String text,
                                Option... _options)

messageRelease

public final void messageRelease(RangeSet transfers,
                                 Option... _options)

messageAcquire

public final Future<Acquired> messageAcquire(RangeSet transfers,
                                             Option... _options)

messageResume

public final Future<MessageResumeResult> messageResume(String destination,
                                                       String resumeId,
                                                       Option... _options)

messageSubscribe

public final void messageSubscribe(String queue,
                                   String destination,
                                   MessageAcceptMode acceptMode,
                                   MessageAcquireMode acquireMode,
                                   String resumeId,
                                   long resumeTtl,
                                   Map<String,Object> arguments,
                                   Option... _options)

messageCancel

public final void messageCancel(String destination,
                                Option... _options)

messageSetFlowMode

public final void messageSetFlowMode(String destination,
                                     MessageFlowMode flowMode,
                                     Option... _options)

messageFlow

public final void messageFlow(String destination,
                              MessageCreditUnit unit,
                              long value,
                              Option... _options)

messageFlush

public final void messageFlush(String destination,
                               Option... _options)

messageStop

public final void messageStop(String destination,
                              Option... _options)

txSelect

public final void txSelect(Option... _options)

txCommit

public final void txCommit(Option... _options)

txRollback

public final void txRollback(Option... _options)

dtxSelect

public final void dtxSelect(Option... _options)

dtxStart

public final Future<XaResult> dtxStart(Xid xid,
                                       Option... _options)

dtxEnd

public final Future<XaResult> dtxEnd(Xid xid,
                                     Option... _options)

dtxCommit

public final Future<XaResult> dtxCommit(Xid xid,
                                        Option... _options)

dtxForget

public final void dtxForget(Xid xid,
                            Option... _options)

dtxGetTimeout

public final Future<GetTimeoutResult> dtxGetTimeout(Xid xid,
                                                    Option... _options)

dtxPrepare

public final Future<XaResult> dtxPrepare(Xid xid,
                                         Option... _options)

dtxRecover

public final Future<RecoverResult> dtxRecover(Option... _options)

dtxRollback

public final Future<XaResult> dtxRollback(Xid xid,
                                          Option... _options)

dtxSetTimeout

public final void dtxSetTimeout(Xid xid,
                                long timeout,
                                Option... _options)

exchangeDeclare

public final void exchangeDeclare(String exchange,
                                  String type,
                                  String alternateExchange,
                                  Map<String,Object> arguments,
                                  Option... _options)

exchangeDelete

public final void exchangeDelete(String exchange,
                                 Option... _options)

exchangeQuery

public final Future<ExchangeQueryResult> exchangeQuery(String name,
                                                       Option... _options)

exchangeBind

public final void exchangeBind(String queue,
                               String exchange,
                               String bindingKey,
                               Map<String,Object> arguments,
                               Option... _options)

exchangeUnbind

public final void exchangeUnbind(String queue,
                                 String exchange,
                                 String bindingKey,
                                 Option... _options)

exchangeBound

public final Future<ExchangeBoundResult> exchangeBound(String exchange,
                                                       String queue,
                                                       String bindingKey,
                                                       Map<String,Object> arguments,
                                                       Option... _options)

queueDeclare

public final void queueDeclare(String queue,
                               String alternateExchange,
                               Map<String,Object> arguments,
                               Option... _options)

queueDelete

public final void queueDelete(String queue,
                              Option... _options)

queuePurge

public final void queuePurge(String queue,
                             Option... _options)

queueQuery

public final Future<QueueQueryResult> queueQuery(String queue,
                                                 Option... _options)

invoke

protected abstract void invoke(Method method)

invoke

protected abstract <T> Future<T> invoke(Method method,
                                        Class<T> resultClass)


Licensed to the Apache Software Foundation