|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
BatchSynchQueue
because the producer has already been unblocked by an unblocking take on the queue.AMQConstant.INTERNAL_ERROR
exceptions relating to the
AMQ protocol.AMQConstant.ACCESS_REFUSED
exceptions relating to the
AMQ protocol.SQLException
.AMQType
, as a fully typed AMQP parameter
value.AMQTypedValue
tagged with its AMQP type.
BatchSynchQueue
to pair together a producer with its data.address
and handles incoming connections with the specified
handler
.
Job
for this filter.
OurCumulativeProtocolDecoder.doDecode(IoSession, ByteBuffer, ProtocolDecoderOutput)
.
AMQDecoder.doDecode(IoSession, ByteBuffer, ProtocolDecoderOutput)
.
IoFuture
.AMQDataBlockDecoder
.
Event
to a Job
, triggering the execution of the job if it is not already running.
IoServiceListener.serviceActivated(IoService, SocketAddress, IoHandler, IoServiceConfig)
for all registered listeners.
IoServiceListener.serviceDeactivated(IoService, SocketAddress, IoHandler, IoServiceConfig)
for all registered listeners.
IoServiceListener.sessionCreated(IoSession)
for all registered listeners.
IoServiceListener.sessionDestroyed(IoSession)
for all registered listeners.
IoServiceListener
s and firing
events.Event
s, into one continuation.IoAcceptor
for socket transport (TCP/IP).IoConnector
for socket transport (TCP/IP).IoFilterChain
for socket transport (TCP/IP).IoConnectorConfig
for SocketConnector
.IoSession
for socket transport (TCP/IP).ProtocolDecoder
that cumulates the content of received
buffers to a cumulative buffer to help users implement decoders.IoHandler
s which is bound on the specified
VmPipeAddress
.${xxx}
, looks up the valuea of 'xxx' as a
system properties and substitutes tham back into the original string, to provide a property value expanded
string.
SerialException
with the specified
detail message.
BatchSynchQueueBase
abstract class by providing an implementation of the underlying
queue as an array.BatchSynchQueue
to producers.BatchSynchQueueBase
abstract class by providing an implementation of the underlying
queue as a linked list.BatchSynchQueue
with its producer.BatchSynchQueue
,
allowing call-backs to be made against the synchronizing strucutre.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |