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

Class ProtonEnginePipelineProxy

java.lang.Object

org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy

All Implemented Interfaces:

EnginePipeline

public class ProtonEnginePipelineProxy
extends Object
implements EnginePipeline

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. The proxy will ensure that any read or write calls enforce Engine state such as not started and shutdown.

Method Summary

Modifier and Type	Method	Description
ProtonEnginePipelineProxy	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.
ProtonEnginePipelineProxy	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.
ProtonEngine	engine()
EngineHandler	find(String name)	Finds and returns first handler that is found in the pipeline that matches the given name.
ProtonEnginePipelineProxy	fireEngineStarting()	Fires an engine starting event to each handler in the pipeline.
ProtonEnginePipelineProxy	fireEngineStateChanged()	Fires an engine state changed event to each handler in the pipeline.
ProtonEnginePipelineProxy	fireFailed(EngineFailedException e)	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.
ProtonEnginePipelineProxy	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.
ProtonEnginePipelineProxy	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.
ProtonEnginePipelineProxy	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.
ProtonEnginePipelineProxy	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.
ProtonEnginePipelineProxy	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.
ProtonEnginePipelineProxy	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.
ProtonEnginePipelineProxy	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.
ProtonEnginePipelineProxy	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.
EngineHandler	first()
EngineHandlerContext	firstContext()
EngineHandler	last()
EngineHandlerContext	lastContext()
ProtonEnginePipelineProxy	remove(String name)	Removes the first handler that is found in the pipeline that matches the given name.
EnginePipeline	remove(EngineHandler handler)	Removes the given EngineHandler from the pipeline if present.
ProtonEnginePipelineProxy	removeFirst()	Removes the first EngineHandler in the pipeline.
ProtonEnginePipelineProxy	removeLast()	Removes the last EngineHandler in the pipeline.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

engine

public ProtonEngine engine()

Specified by:

engine in interface EnginePipeline

Returns:

the Engine that this pipeline is linked to.

addFirst

public ProtonEnginePipelineProxy addFirst(String name,
 EngineHandler handler)

Description copied from interface: EnginePipeline

Adds the given handler to the front of the pipeline with the given name stored for later lookup or remove operations. It is not mandatory that each handler have unique names although if handlers do share a name the EnginePipeline.remove(String) method will only remove them one at a time starting from the first in the pipeline.

Specified by:

addFirst in interface EnginePipeline

Parameters:

name - The name to assign to the handler

handler - The EngineHandler to add into the pipeline.

Returns:

this EnginePipeline.

addLast

public ProtonEnginePipelineProxy addLast(String name,
 EngineHandler handler)

Description copied from interface: EnginePipeline

Adds the given handler to the end of the pipeline with the given name stored for later lookup or remove operations. It is not mandatory that each handler have unique names although if handlers do share a name the EnginePipeline.remove(String) method will only remove them one at a time starting from the first in the pipeline.

Specified by:

addLast in interface EnginePipeline

Parameters:

name - The name to assign to the handler

handler - The EngineHandler to add into the pipeline.

Returns:

this EnginePipeline.

removeFirst

public ProtonEnginePipelineProxy removeFirst()

Description copied from interface: EnginePipeline

Removes the first EngineHandler in the pipeline.

Specified by:

removeFirst in interface EnginePipeline

Returns:

this EnginePipeline.

removeLast

public ProtonEnginePipelineProxy removeLast()

Description copied from interface: EnginePipeline

Removes the last EngineHandler in the pipeline.

Specified by:

removeLast in interface EnginePipeline

Returns:

this EnginePipeline.

remove

public ProtonEnginePipelineProxy remove(String name)

Description copied from interface: EnginePipeline

Removes the first handler that is found in the pipeline that matches the given name.

Specified by:

remove in interface EnginePipeline

Parameters:

name - The name to search for in the pipeline moving from first to last.

Returns:

this EnginePipeline.

remove

public EnginePipeline remove(EngineHandler handler)

Description copied from interface: EnginePipeline

Removes the given EngineHandler from the pipeline if present.

Specified by:

remove in interface EnginePipeline

Parameters:

handler - The handler instance to remove if contained in the pipeline.

Returns:

this EnginePipeline.

find

public EngineHandler find(String name)

Description copied from interface: EnginePipeline

Finds and returns first handler that is found in the pipeline that matches the given name.

Specified by:

find in interface EnginePipeline

Parameters:

name - The name to search for in the pipeline moving from first to last.

Returns:

the EngineHandler that matches the given name or null if none in the pipeline.

first

public EngineHandler first()

Specified by:

first in interface EnginePipeline

Returns:

the first EngineHandler in the pipeline or null if empty.

last

public EngineHandler last()

Specified by:

last in interface EnginePipeline

Returns:

the last EngineHandler in the pipeline or null if empty.

firstContext

public EngineHandlerContext firstContext()

Specified by:

firstContext in interface EnginePipeline

Returns:

the first EngineHandlerContext in the pipeline or null if empty.

lastContext

public EngineHandlerContext lastContext()

Specified by:

lastContext in interface EnginePipeline

Returns:

the last EngineHandlerContext in the pipeline or null if empty.

fireEngineStarting

public ProtonEnginePipelineProxy fireEngineStarting()

Description copied from interface: EnginePipeline

Fires an engine starting event to each handler in the pipeline. Should be used by the engine implementation to signal its handlers that they should initialize.

Specified by:

fireEngineStarting in interface EnginePipeline

Returns:

this EnginePipeline.

fireEngineStateChanged

public ProtonEnginePipelineProxy fireEngineStateChanged()

Description copied from interface: EnginePipeline

Fires an engine state changed event to each handler in the pipeline. Should be used by the engine implementation to signal its handlers that they should respond to the new engine state, e.g. the engine failed or was shutdown.

Specified by:

fireEngineStateChanged in interface EnginePipeline

Returns:

this EnginePipeline.

fireFailed

public ProtonEnginePipelineProxy fireFailed(EngineFailedException e)

Description copied from interface: EnginePipeline

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.

Specified by:

fireFailed in interface EnginePipeline

Parameters:

e - The cause of the engine failure.

Returns:

this EnginePipeline.

fireRead

public ProtonEnginePipelineProxy fireRead(ProtonBuffer input)

Description copied from interface: EnginePipeline

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. If the read events reaches the head of the pipeline and is not handled by any handler an error is thrown and the engine should enter the failed state.

Specified by:

fireRead in interface EnginePipeline

Parameters:

input - The ProtonBuffer to inject into the engine pipeline.

Returns:

this EnginePipeline.

fireRead

public ProtonEnginePipelineProxy fireRead(HeaderEnvelope header)

Description copied from interface: EnginePipeline

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. If the read events reaches the head of the pipeline and is not handled by any handler an error is thrown and the engine should enter the failed state.

Specified by:

fireRead in interface EnginePipeline

Parameters:

header - The HeaderEnvelope to inject into the engine pipeline.

Returns:

this EnginePipeline.

fireRead

public ProtonEnginePipelineProxy fireRead(SASLEnvelope envelope)

Description copied from interface: EnginePipeline

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. If the read events reaches the head of the pipeline and is not handled by any handler an error is thrown and the engine should enter the failed state.

Specified by:

fireRead in interface EnginePipeline

Parameters:

envelope - The SASLEnvelope to inject into the engine pipeline.

Returns:

this EnginePipeline.

fireRead

public ProtonEnginePipelineProxy fireRead(IncomingAMQPEnvelope envelope)

Description copied from interface: EnginePipeline

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. If the read events reaches the head of the pipeline and is not handled by any handler an error is thrown and the engine should enter the failed state.

Specified by:

fireRead in interface EnginePipeline

Parameters:

envelope - The IncomingAMQPEnvelope to inject into the engine pipeline.

Returns:

this EnginePipeline.

fireWrite

public ProtonEnginePipelineProxy fireWrite(HeaderEnvelope envelope)

Description copied from interface: EnginePipeline

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. If the write events reaches the tail of the pipeline and is not handled by any handler an error is thrown and the engine should enter the failed state. It is expected that after the fire write method returns the given HeaderEnvelope will have been written or if held for later the object must be copied.

Specified by:

fireWrite in interface EnginePipeline

Parameters:

envelope - The HeaderEnvelope to inject into the engine pipeline.

Returns:

this EnginePipeline.

fireWrite

public ProtonEnginePipelineProxy fireWrite(OutgoingAMQPEnvelope envelope)

Description copied from interface: EnginePipeline

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. If the write events reaches the tail of the pipeline and is not handled by any handler an error is thrown and the engine should enter the failed state. It is expected that after the fire write method returns the given OutgoingAMQPEnvelope will have been written or if held for later the object must be copied. When the payload given exceeds the maximum allowed frame size when encoded into an outbound frame the encoding handler should either throw an error in the case that the performative being written cannot truncate its payload or should invoke the payload to large handler of the envelope before re-encoding the outbound performative and truncating the payload.

Specified by:

fireWrite in interface EnginePipeline

Parameters:

envelope - The OutgoingAMQPEnvelope to inject into the engine pipeline.

Returns:

this EnginePipeline.

fireWrite

public ProtonEnginePipelineProxy fireWrite(SASLEnvelope envelope)

Description copied from interface: EnginePipeline

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. If the write events reaches the tail of the pipeline and is not handled by any handler an error is thrown and the engine should enter the failed state. It is expected that after the fire write method returns the given SASLEnvelope will have been written or if held for later the object must be copied.

Specified by:

fireWrite in interface EnginePipeline

Parameters:

envelope - The SASLEnvelope to inject into the engine pipeline.

Returns:

this EnginePipeline.

fireWrite

public ProtonEnginePipelineProxy fireWrite(ProtonBuffer buffer,
 Runnable ioComplete)

Description copied from interface: EnginePipeline

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. If the write events reaches the tail of the pipeline and is not handled by any handler an error is thrown and the engine should enter the failed state.

Specified by:

fireWrite in interface EnginePipeline

Parameters:

buffer - The ProtonBuffer to inject into the engine pipeline.

ioComplete - An optional callback that should be signaled when the underlying transport complete the I/O write

Returns:

this EnginePipeline.