org.apache.qpid.transport
Class SessionInvoker
java.lang.Object
org.apache.qpid.transport.SessionInvoker
- Direct Known Subclasses:
- Session
public abstract class SessionInvoker
- extends Object
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
|
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 |
SessionInvoker
public SessionInvoker()
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