Methods in org.apache.qpid.transport with parameters of type Option |
void |
Connection.close(ConnectionCloseCode replyCode,
String replyText,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionClose(ConnectionCloseCode replyCode,
String replyText,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionCloseOk(Option... _options)
|
(package private) void |
ConnectionInvoker.connectionHeartbeat(Option... _options)
|
(package private) void |
ConnectionInvoker.connectionOpen(String virtualHost,
List<Object> capabilities,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionOpenOk(List<Object> knownHosts,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionRedirect(String host,
List<Object> knownHosts,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionSecure(byte[] challenge,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionSecureOk(byte[] response,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionStart(Map<String,Object> serverProperties,
List<Object> mechanisms,
List<Object> locales,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionStartOk(Map<String,Object> clientProperties,
String mechanism,
byte[] response,
String locale,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionTune(int channelMax,
int maxFrameSize,
int heartbeatMin,
int heartbeatMax,
Option... _options)
|
(package private) void |
ConnectionInvoker.connectionTuneOk(int channelMax,
int maxFrameSize,
int heartbeat,
Option... _options)
|
Future<XaResult> |
SessionInvoker.dtxCommit(Xid xid,
Option... _options)
|
Future<XaResult> |
SessionInvoker.dtxEnd(Xid xid,
Option... _options)
|
void |
SessionInvoker.dtxForget(Xid xid,
Option... _options)
|
Future<GetTimeoutResult> |
SessionInvoker.dtxGetTimeout(Xid xid,
Option... _options)
|
Future<XaResult> |
SessionInvoker.dtxPrepare(Xid xid,
Option... _options)
|
Future<RecoverResult> |
SessionInvoker.dtxRecover(Option... _options)
|
Future<XaResult> |
SessionInvoker.dtxRollback(Xid xid,
Option... _options)
|
void |
SessionInvoker.dtxSelect(Option... _options)
|
void |
SessionInvoker.dtxSetTimeout(Xid xid,
long timeout,
Option... _options)
|
Future<XaResult> |
SessionInvoker.dtxStart(Xid xid,
Option... _options)
|
void |
SessionInvoker.exchangeBind(String queue,
String exchange,
String bindingKey,
Map<String,Object> arguments,
Option... _options)
|
Future<ExchangeBoundResult> |
SessionInvoker.exchangeBound(String exchange,
String queue,
String bindingKey,
Map<String,Object> arguments,
Option... _options)
|
void |
SessionInvoker.exchangeDeclare(String exchange,
String type,
String alternateExchange,
Map<String,Object> arguments,
Option... _options)
|
void |
SessionInvoker.exchangeDelete(String exchange,
Option... _options)
|
Future<ExchangeQueryResult> |
SessionInvoker.exchangeQuery(String name,
Option... _options)
|
void |
SessionInvoker.exchangeUnbind(String queue,
String exchange,
String bindingKey,
Option... _options)
|
void |
SessionInvoker.executionException(ExecutionErrorCode errorCode,
int commandId,
short classCode,
short commandCode,
short fieldIndex,
String description,
Map<String,Object> errorInfo,
Option... _options)
|
void |
SessionInvoker.executionResult(int commandId,
Struct value,
Option... _options)
|
void |
SessionInvoker.executionSync(Option... _options)
|
void |
Session.flushProcessed(Option... options)
|
void |
SessionInvoker.messageAccept(RangeSet transfers,
Option... _options)
|
Future<Acquired> |
SessionInvoker.messageAcquire(RangeSet transfers,
Option... _options)
|
void |
SessionInvoker.messageCancel(String destination,
Option... _options)
|
void |
SessionInvoker.messageFlow(String destination,
MessageCreditUnit unit,
long value,
Option... _options)
|
void |
SessionInvoker.messageFlush(String destination,
Option... _options)
|
void |
SessionInvoker.messageReject(RangeSet transfers,
MessageRejectCode code,
String text,
Option... _options)
|
void |
SessionInvoker.messageRelease(RangeSet transfers,
Option... _options)
|
Future<MessageResumeResult> |
SessionInvoker.messageResume(String destination,
String resumeId,
Option... _options)
|
void |
SessionInvoker.messageSetFlowMode(String destination,
MessageFlowMode flowMode,
Option... _options)
|
void |
SessionInvoker.messageStop(String destination,
Option... _options)
|
void |
SessionInvoker.messageSubscribe(String queue,
String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
String resumeId,
long resumeTtl,
Map<String,Object> arguments,
Option... _options)
|
void |
Session.messageTransfer(String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
Header header,
byte[] body,
Option... _options)
|
void |
SessionInvoker.messageTransfer(String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
Header header,
ByteBuffer body,
Option... _options)
|
void |
Session.messageTransfer(String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
Header header,
String body,
Option... _options)
|
void |
SessionInvoker.queueDeclare(String queue,
String alternateExchange,
Map<String,Object> arguments,
Option... _options)
|
void |
SessionInvoker.queueDelete(String queue,
Option... _options)
|
void |
SessionInvoker.queuePurge(String queue,
Option... _options)
|
Future<QueueQueryResult> |
SessionInvoker.queueQuery(String queue,
Option... _options)
|
(package private) void |
SessionInvoker.sessionAttach(byte[] name,
Option... _options)
|
(package private) void |
SessionInvoker.sessionAttached(byte[] name,
Option... _options)
|
(package private) void |
SessionInvoker.sessionCommandPoint(int commandId,
long commandOffset,
Option... _options)
|
(package private) void |
SessionInvoker.sessionCompleted(RangeSet commands,
Option... _options)
|
(package private) void |
SessionInvoker.sessionConfirmed(RangeSet commands,
List<Object> fragments,
Option... _options)
|
(package private) void |
SessionInvoker.sessionDetach(byte[] name,
Option... _options)
|
(package private) void |
SessionInvoker.sessionDetached(byte[] name,
SessionDetachCode code,
Option... _options)
|
(package private) void |
SessionInvoker.sessionExpected(RangeSet commands,
List<Object> fragments,
Option... _options)
|
(package private) void |
SessionInvoker.sessionFlush(Option... _options)
|
(package private) void |
SessionInvoker.sessionGap(RangeSet commands,
Option... _options)
|
(package private) void |
SessionInvoker.sessionKnownCompleted(RangeSet commands,
Option... _options)
|
(package private) void |
SessionInvoker.sessionRequestTimeout(long timeout,
Option... _options)
|
(package private) void |
SessionInvoker.sessionTimeout(long timeout,
Option... _options)
|
void |
SessionInvoker.txCommit(Option... _options)
|
void |
SessionInvoker.txRollback(Option... _options)
|
void |
SessionInvoker.txSelect(Option... _options)
|
Constructors in org.apache.qpid.transport with parameters of type Option |
ConnectionClose(ConnectionCloseCode replyCode,
String replyText,
Option... _options)
|
ConnectionCloseOk(Option... _options)
|
ConnectionHeartbeat(Option... _options)
|
ConnectionOpen(String virtualHost,
List<Object> capabilities,
Option... _options)
|
ConnectionOpenOk(List<Object> knownHosts,
Option... _options)
|
ConnectionRedirect(String host,
List<Object> knownHosts,
Option... _options)
|
ConnectionSecure(byte[] challenge,
Option... _options)
|
ConnectionSecureOk(byte[] response,
Option... _options)
|
ConnectionStart(Map<String,Object> serverProperties,
List<Object> mechanisms,
List<Object> locales,
Option... _options)
|
ConnectionStartOk(Map<String,Object> clientProperties,
String mechanism,
byte[] response,
String locale,
Option... _options)
|
ConnectionTune(int channelMax,
int maxFrameSize,
int heartbeatMin,
int heartbeatMax,
Option... _options)
|
ConnectionTuneOk(int channelMax,
int maxFrameSize,
int heartbeat,
Option... _options)
|
DeliveryProperties(MessageDeliveryPriority priority,
MessageDeliveryMode deliveryMode,
long ttl,
long timestamp,
long expiration,
String exchange,
String routingKey,
String resumeId,
long resumeTtl,
Option... _options)
|
DtxCommit(Xid xid,
Option... _options)
|
DtxEnd(Xid xid,
Option... _options)
|
DtxForget(Xid xid,
Option... _options)
|
DtxGetTimeout(Xid xid,
Option... _options)
|
DtxPrepare(Xid xid,
Option... _options)
|
DtxRecover(Option... _options)
|
DtxRollback(Xid xid,
Option... _options)
|
DtxSelect(Option... _options)
|
DtxSetTimeout(Xid xid,
long timeout,
Option... _options)
|
DtxStart(Xid xid,
Option... _options)
|
ExchangeBind(String queue,
String exchange,
String bindingKey,
Map<String,Object> arguments,
Option... _options)
|
ExchangeBound(String exchange,
String queue,
String bindingKey,
Map<String,Object> arguments,
Option... _options)
|
ExchangeBoundResult(Option... _options)
|
ExchangeDeclare(String exchange,
String type,
String alternateExchange,
Map<String,Object> arguments,
Option... _options)
|
ExchangeDelete(String exchange,
Option... _options)
|
ExchangeQuery(String name,
Option... _options)
|
ExchangeQueryResult(String type,
Map<String,Object> arguments,
Option... _options)
|
ExchangeUnbind(String queue,
String exchange,
String bindingKey,
Option... _options)
|
ExecutionException(ExecutionErrorCode errorCode,
int commandId,
short classCode,
short commandCode,
short fieldIndex,
String description,
Map<String,Object> errorInfo,
Option... _options)
|
ExecutionResult(int commandId,
Struct value,
Option... _options)
|
ExecutionSync(Option... _options)
|
FragmentProperties(long fragmentSize,
Option... _options)
|
MessageAccept(RangeSet transfers,
Option... _options)
|
MessageAcquire(RangeSet transfers,
Option... _options)
|
MessageCancel(String destination,
Option... _options)
|
MessageFlow(String destination,
MessageCreditUnit unit,
long value,
Option... _options)
|
MessageFlush(String destination,
Option... _options)
|
MessageReject(RangeSet transfers,
MessageRejectCode code,
String text,
Option... _options)
|
MessageRelease(RangeSet transfers,
Option... _options)
|
MessageResume(String destination,
String resumeId,
Option... _options)
|
MessageSetFlowMode(String destination,
MessageFlowMode flowMode,
Option... _options)
|
MessageStop(String destination,
Option... _options)
|
MessageSubscribe(String queue,
String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
String resumeId,
long resumeTtl,
Map<String,Object> arguments,
Option... _options)
|
MessageTransfer(String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
Header header,
ByteBuffer body,
Option... _options)
|
QueueDeclare(String queue,
String alternateExchange,
Map<String,Object> arguments,
Option... _options)
|
QueueDelete(String queue,
Option... _options)
|
QueuePurge(String queue,
Option... _options)
|
QueueQuery(String queue,
Option... _options)
|
QueueQueryResult(String queue,
String alternateExchange,
Map<String,Object> arguments,
long messageCount,
long subscriberCount,
Option... _options)
|
SessionAttach(byte[] name,
Option... _options)
|
SessionAttached(byte[] name,
Option... _options)
|
SessionCommandPoint(int commandId,
long commandOffset,
Option... _options)
|
SessionCompleted(RangeSet commands,
Option... _options)
|
SessionConfirmed(RangeSet commands,
List<Object> fragments,
Option... _options)
|
SessionDetach(byte[] name,
Option... _options)
|
SessionDetached(byte[] name,
SessionDetachCode code,
Option... _options)
|
SessionExpected(RangeSet commands,
List<Object> fragments,
Option... _options)
|
SessionFlush(Option... _options)
|
SessionGap(RangeSet commands,
Option... _options)
|
SessionHeader(Option... _options)
|
SessionKnownCompleted(RangeSet commands,
Option... _options)
|
SessionRequestTimeout(long timeout,
Option... _options)
|
SessionTimeout(long timeout,
Option... _options)
|
TxCommit(Option... _options)
|
TxRollback(Option... _options)
|
TxSelect(Option... _options)
|