|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
AMQP.REPLY_SUCCESS close code
and message 'OK'.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
ConfirmListener.
FlowListener.
true, or else return false.
ReturnListener.
Command which accumulates
method, header and body from a series of frames, unless these are
supplied at construction time.AMQP.Basic.Get
AMQP.Basic.Get
JsonRpcClient.call(String,Object[]), but takes the
method name from the first entry in args, and the
parameters from subsequent entries.
1.._channelMax).ConfirmListeners.
FlowListeners.
ReturnListeners.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
the
six-argument close method, passing -1 for the timeout, and
false for the abort flag.
AMQP.REPLY_SUCCESS close code
and message 'OK'.
JsonRpcClient.call(String[]) to ad-hoc convert
strings into the required data types for a call.
Connection to an AMQP broker.ContentHeader from a
DataInputStream.ContentHeader.Consumer.ExceptionHandler used by AMQConnection.AMQCommand.checkEmptyFrameSize(), an assertion checked at
startup.
Envelope with the specified construction parameters
Envelope included in this response
Method held within this Command.
Method held within this Command.
ProcedureDescription for this service
BasicProperties included in this response
Channel.basicGet(java.lang.String, boolean) message-retrieval method call
- essentially a static bean "holder" with message response data.GetResponse with the specified construction parameters
Channel.basicCancel(java.lang.String).
Consumer.handleCancel(String)
Channel.basicCancel(java.lang.String).
Consumer.handleCancelOk(java.lang.String).
Channel.basicConsume(java.lang.String, com.rabbitmq.client.Consumer) methods.
basic.deliver is received for this consumer.
Consumer.handleDelivery(java.lang.String, com.rabbitmq.client.Envelope, com.rabbitmq.client.AMQP.BasicProperties, byte[]).
basic.recover-ok is received
in reply to a basic.recover.
Consumer.handleRecoverOk(java.lang.String).
Consumer.handleShutdownSignal(java.lang.String, com.rabbitmq.client.ShutdownSignalException).
BitSet representation of the free integers.bottom, top].
LongStrings.String, LongString, Integer, BigDecimal, Date,
or (recursively) a Map of the enclosing type.
RpcClient.mapCall(Map).
AMQContentHeader.Method arguments from a
DataInputStream.ValueReader.
BlockingCell.uninterruptibleGet(int)
ShutdownSignalException.
Consumer with
straightforward blocking semantics.Frame from the underlying data connection.
key to pool of item queues, with an empty queue.
ConfirmListener.
FlowListener.
ReturnListener.
Method to the broker and waits for the
next in-bound Command from the broker: only for use from
non-connection-MainLoop threads!
addIfNotPresent,
poll, contains, and isEmpty)
which restricts a queue element to appear at most once.ShutdownListeners and remembers the reason for a shutdown.Tracer.Logger.log(String).
Tracer.Logger.log(String).
AMQCommand.transmit(com.rabbitmq.client.impl.AMQChannel)
Tracer.Logger designed to print Strings to a designated OutputStream
on a private thread.Tracer.AsyncLogger.Tracer.AsyncLogger(OutputStream, int) with a one-second flush interval.
OutputStream with flushes every flushInterval milliseconds.
Method object was supplied that was not
expected.Version instance.
Channelsspecification in Channeling Work, Nov 2010 (channels.pdf).
Frame to the underlying data connection.
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||