Package org.apache.qpid.protonj2.engine
Interface EngineHandlerContext
-
- All Known Implementing Classes:
ProtonEngineHandlerContext
public interface EngineHandlerContextContext provided to EngineHandler events to allow further event propagation
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Engineengine()voidfireEngineStarting()Fires the engine starting event into the next handler in theEnginePipelinechain.voidfireEngineStateChanged()Fires the engine state changed event into the next handler in theEnginePipelinechain.voidfireFailed(EngineFailedException failure)Fires theEnginefailed event into the next handler in theEnginePipelinechain.voidfireRead(ProtonBuffer buffer)Fires a read of ProtonBuffer events into the previous handler in theEnginePipelinefor further processing.voidfireRead(HeaderEnvelope header)Fires a read of HeaderFrame events into the previous handler in theEnginePipelinefor further processing.voidfireRead(IncomingAMQPEnvelope envelope)Fires a read of IncomingProtocolFrame events into the previous handler in theEnginePipelinefor further processing.voidfireRead(SASLEnvelope envelope)Fires a read of SASL events into the previous handler in theEnginePipelinefor further processing.voidfireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)Fires a write of ProtonBuffer events into the next handler in theEnginePipelinefor further processing.voidfireWrite(HeaderEnvelope envelope)Fires a write of HeaderFrame events into the next handler in theEnginePipelinefor further processing.voidfireWrite(OutgoingAMQPEnvelope envelope)Fires a write ofOutgoingAMQPEnvelopeevents into the next handler in theEnginePipelinefor further processing.voidfireWrite(SASLEnvelope envelope)Fires a write ofSASLEnvelopeevents into the next handler in theEnginePipelinefor further processing.EngineHandlerhandler()java.lang.Stringname()
-
-
-
Method Detail
-
handler
EngineHandler handler()
- Returns:
- the
EngineHandlerthat is associated with the context.
-
name
java.lang.String name()
- Returns:
- the name that assigned to this
EngineHandlerwhen added to theEnginePipeline.
-
fireEngineStarting
void fireEngineStarting()
Fires the engine starting event into the next handler in theEnginePipelinechain.
-
fireEngineStateChanged
void fireEngineStateChanged()
Fires the engine state changed event into the next handler in theEnginePipelinechain. The state change events occur after the engine starting event and generally signify that the engine has been shutdown normally.
-
fireFailed
void fireFailed(EngineFailedException failure)
Fires theEnginefailed event into the next handler in theEnginePipelinechain.- Parameters:
failure- The exception that describes the conditions under which the engine failed.
-
fireRead
void fireRead(ProtonBuffer buffer)
Fires a read of ProtonBuffer events into the previous handler in theEnginePipelinefor further processing.- Parameters:
buffer- TheProtonBufferthat carries the bytes read.
-
fireRead
void fireRead(HeaderEnvelope header)
Fires a read of HeaderFrame events into the previous handler in theEnginePipelinefor further processing.- Parameters:
header- TheHeaderEnvelopethat carries the header bytes read.
-
fireRead
void fireRead(SASLEnvelope envelope)
Fires a read of SASL events into the previous handler in theEnginePipelinefor further processing.- Parameters:
envelope- TheSASLEnvelopethat carries the SASL performative read.
-
fireRead
void fireRead(IncomingAMQPEnvelope envelope)
Fires a read of IncomingProtocolFrame events into the previous handler in theEnginePipelinefor further processing.- Parameters:
envelope- TheIncomingAMQPEnvelopethat carries the AMQP performative read.
-
fireWrite
void fireWrite(OutgoingAMQPEnvelope envelope)
Fires a write ofOutgoingAMQPEnvelopeevents into the next handler in theEnginePipelinefor further processing.- Parameters:
envelope- TheOutgoingAMQPEnvelopethat carries the AMQP performative being written.
-
fireWrite
void fireWrite(SASLEnvelope envelope)
Fires a write ofSASLEnvelopeevents into the next handler in theEnginePipelinefor further processing.- Parameters:
envelope- TheSASLEnvelopethat carries the SASL performative being written.
-
fireWrite
void fireWrite(HeaderEnvelope envelope)
Fires a write of HeaderFrame events into the next handler in theEnginePipelinefor further processing.- Parameters:
envelope- TheHeaderEnvelopethat carries the AMQP Header being written.
-
fireWrite
void fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)
Fires a write of ProtonBuffer events into the next handler in theEnginePipelinefor further processing.- Parameters:
buffer- TheProtonBufferthat carries the bytes being written.ioComplete- An optionalRunnablecallback that is signaled when the I/O completes successfully.
-
-