|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
prepareEnqueue
method).
Pipe
types.prepareEnqueue
method).
EventPipelineRunner
that will be used to get
events from the Sources to the EventHandler.
null
if there is
nothing left on the queue or in case of a timeout while
attempting to obtain the mutex.
num
available elements.
null
if there is
nothing left on the queue or in case of a timeout while
attempting to obtain the mutex.
num
available elements.
SinkException
instance.
SinkException
instance.
EventHandler
takes care of processing specific events
in an event-based architecture.AbstractThreadPolicy.startLoop()
method to do any further
initialization.
Sink
implementation that
multicasts enqueue operations to the contained and concrete sink
objects.PreparedEnqueue
is an object returned from a
prepareEnqueue
method that allows you to either commit
or abort the enqueue operation.buf
and returns them in an array.
Pipe
in milliseconds.
SinkClosedException
with an associated
message.
SinkClosedException
with an associated
message and the original exception that caused the problem.
SinkException
instance.
SinkException
instance.
SinkFullException
with an associated
message.
SinkClosedException
with an associated
message and the original exception that caused the problem.
Pipe
.
AbstractThreadPolicy.endLoop()
method to do any
further tear down.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |