Constructor and Description |
---|
SessionInvoker() |
Modifier and Type | Method and Description |
---|---|
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) |
void |
txCommit(Option... _options) |
void |
txRollback(Option... _options) |
void |
txSelect(Option... _options) |
public final void executionSync(Option... _options)
public final void executionException(ExecutionErrorCode errorCode, int commandId, short classCode, short commandCode, short fieldIndex, String description, Map<String,Object> errorInfo, Option... _options)
public final void messageTransfer(String destination, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, Header header, ByteBuffer body, Option... _options)
public final void messageReject(RangeSet transfers, MessageRejectCode code, String text, Option... _options)
public final Future<MessageResumeResult> messageResume(String destination, String resumeId, Option... _options)
public final void messageSubscribe(String queue, String destination, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, String resumeId, long resumeTtl, Map<String,Object> arguments, Option... _options)
public final void messageSetFlowMode(String destination, MessageFlowMode flowMode, Option... _options)
public final void messageFlow(String destination, MessageCreditUnit unit, long value, Option... _options)
public final void txSelect(Option... _options)
public final void txCommit(Option... _options)
public final void txRollback(Option... _options)
public final void dtxSelect(Option... _options)
public final Future<GetTimeoutResult> dtxGetTimeout(Xid xid, Option... _options)
public final Future<RecoverResult> dtxRecover(Option... _options)
public final void exchangeDeclare(String exchange, String type, String alternateExchange, Map<String,Object> arguments, Option... _options)
public final Future<ExchangeQueryResult> exchangeQuery(String name, Option... _options)
public final void exchangeBind(String queue, String exchange, String bindingKey, Map<String,Object> arguments, Option... _options)
public final void exchangeUnbind(String queue, String exchange, String bindingKey, Option... _options)
public final Future<ExchangeBoundResult> exchangeBound(String exchange, String queue, String bindingKey, Map<String,Object> arguments, Option... _options)
public final void queueDeclare(String queue, String alternateExchange, Map<String,Object> arguments, Option... _options)
public final Future<QueueQueryResult> queueQuery(String queue, Option... _options)
protected abstract void invoke(Method method)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.