Package | Description |
---|---|
org.apache.qpid.server.protocol.v0_10 | |
org.apache.qpid.transport |
Modifier and Type | Method and Description |
---|---|
protected void |
ServerConnection.sendConnectionClose(ConnectionCloseCode replyCode,
String replyText,
Option... _options) |
Modifier and Type | Method and Description |
---|---|
static Option |
Option.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Option[] |
Option.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
Connection.close(ConnectionCloseCode replyCode,
String replyText,
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) |
protected void |
Connection.sendConnectionClose(ConnectionCloseCode replyCode,
String replyText,
Option... _options) |
void |
SessionInvoker.txCommit(Option... _options) |
void |
SessionInvoker.txRollback(Option... _options) |
void |
SessionInvoker.txSelect(Option... _options) |
Constructor and Description |
---|
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) |
MessageTransfer(String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
Header header,
Collection<QpidByteBuffer> 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) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.