Uses of Interface
org.apache.qpid.protonj2.engine.EnginePipeline

Packages that use EnginePipeline

Package	Description
org.apache.qpid.protonj2.engine
org.apache.qpid.protonj2.engine.impl

Uses of EnginePipeline in org.apache.qpid.protonj2.engine

Methods in org.apache.qpid.protonj2.engine that return EnginePipeline

Modifier and Type	Method	Description
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)	Removes the given EngineHandler from the pipeline if present.
EnginePipeline	EnginePipeline.removeFirst()	Removes the first EngineHandler in the pipeline.
EnginePipeline	EnginePipeline.removeLast()	Removes the last EngineHandler in the pipeline.

Uses of EnginePipeline in org.apache.qpid.protonj2.engine.impl

Classes in org.apache.qpid.protonj2.engine.impl that implement EnginePipeline

Modifier and Type	Class	Description
class	ProtonEnginePipeline	Pipeline of EngineHandler instances used to process IO
class	ProtonEnginePipelineProxy	Wrapper around the internal ProtonEnginePipeline used to present a guarded pipeline to the outside world when the Engine.pipeline() method is used to gain access to the pipeline.

Methods in org.apache.qpid.protonj2.engine.impl that return EnginePipeline

Modifier and Type	Method	Description
EnginePipeline	ProtonEngine.pipeline()
EnginePipeline	ProtonEnginePipeline.remove(EngineHandler handler)
EnginePipeline	ProtonEnginePipelineProxy.remove(EngineHandler handler)