|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Pipe
types.prepareEnqueue
method).
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.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
in milliseconds.
Pipe
.
AbstractThreadPolicy.endLoop()
method to do any
further tear down.
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |