EnginePipeline |
EnginePipeline.addFirst(String name,
EngineHandler handler) |
Adds the given handler to the front of the pipeline with the given name stored for
later lookup or remove operations.
|
EnginePipeline |
EnginePipeline.addLast(String name,
EngineHandler handler) |
Adds the given handler to the end of the pipeline with the given name stored for
later lookup or remove operations.
|
EnginePipeline |
EnginePipeline.fireEngineStarting() |
Fires an engine starting event to each handler in the pipeline.
|
EnginePipeline |
EnginePipeline.fireEngineStateChanged() |
Fires an engine state changed event to each handler in the pipeline.
|
EnginePipeline |
EnginePipeline.fireFailed(EngineFailedException failure) |
Fires an engine failed event into each EngineHandler in the pipeline indicating
that the engine is now failed and should not accept or produce new work. |
EnginePipeline |
EnginePipeline.fireRead(ProtonBuffer input) |
Fires a read event consisting of the given ProtonBuffer into the pipeline starting
from the last EngineHandler in the pipeline and moving through each until the incoming
work is fully processed. |
EnginePipeline |
EnginePipeline.fireRead(HeaderEnvelope header) |
Fires a read event consisting of the given HeaderEnvelope into the pipeline starting
from the last EngineHandler in the pipeline and moving through each until the incoming
work is fully processed. |
EnginePipeline |
EnginePipeline.fireRead(IncomingAMQPEnvelope envelope) |
Fires a read event consisting of the given IncomingAMQPEnvelope into the pipeline starting
from the last EngineHandler in the pipeline and moving through each until the incoming
work is fully processed. |
EnginePipeline |
EnginePipeline.fireRead(SASLEnvelope envelope) |
Fires a read event consisting of the given SASLEnvelope into the pipeline starting
from the last EngineHandler in the pipeline and moving through each until the incoming
work is fully processed. |
EnginePipeline |
EnginePipeline.fireWrite(ProtonBuffer buffer,
Runnable ioComplete) |
Fires a write event consisting of the given ProtonBuffer into the pipeline starting
from the first EngineHandler in the pipeline and moving through each until the outgoing
work is fully processed. |
EnginePipeline |
EnginePipeline.fireWrite(HeaderEnvelope envelope) |
Fires a write event consisting of the given HeaderEnvelope into the pipeline starting
from the first EngineHandler in the pipeline and moving through each until the outgoing
work is fully processed. |
EnginePipeline |
EnginePipeline.fireWrite(OutgoingAMQPEnvelope envelope) |
Fires a write event consisting of the given OutgoingAMQPEnvelope into the pipeline starting
from the first EngineHandler in the pipeline and moving through each until the outgoing
work is fully processed. |
EnginePipeline |
EnginePipeline.fireWrite(SASLEnvelope envelope) |
Fires a write event consisting of the given SASLEnvelope into the pipeline starting
from the first EngineHandler in the pipeline and moving through each until the outgoing
work is fully processed. |
EnginePipeline |
Engine.pipeline() |
Gets the EnginePipeline for this Engine.
|
EnginePipeline |
EnginePipeline.remove(String name) |
Removes the first handler that is found in the pipeline that matches the given name.
|
EnginePipeline |
EnginePipeline.remove(EngineHandler handler) |
|
EnginePipeline |
EnginePipeline.removeFirst() |
|
EnginePipeline |
EnginePipeline.removeLast() |
|