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

Class ProtonFrameLoggingHandler

java.lang.Object

org.apache.qpid.protonj2.engine.impl.ProtonFrameLoggingHandler

All Implemented Interfaces:

EngineHandler

public class ProtonFrameLoggingHandler
extends Object
implements EngineHandler

Handler that will log incoming and outgoing Frames

Constructor Summary

Constructors

Constructor	Description
ProtonFrameLoggingHandler()

Method Summary

Modifier and Type	Method	Description
void	handlerAdded(EngineHandlerContext context)	Called when the handler is successfully added to the EnginePipeline and will later be initialized before use.
void	handleRead(EngineHandlerContext context, HeaderEnvelope envelope)	Handle the receipt of an incoming AMQP Header or SASL Header based on the current state of this handler.
void	handleRead(EngineHandlerContext context, IncomingAMQPEnvelope envelope)	Handle the receipt of an incoming AMQP envelope based on the current state of this handler.
void	handleRead(EngineHandlerContext context, SASLEnvelope envelope)	Handle the receipt of an incoming SASL performative based on the current state of this handler.
void	handleWrite(EngineHandlerContext context, HeaderEnvelope envelope)	Handles write of AMQPHeader either by directly writing it to the output target or by converting it to bytes and firing a write using the ProtonBuffer based API in EngineHandlerContext.fireWrite(ProtonBuffer, Runnable)
void	handleWrite(EngineHandlerContext context, OutgoingAMQPEnvelope envelope)	Handles write of AMQP performative envelope either by directly writing it to the output target or by converting it to bytes and firing a write using the ProtonBuffer based API in EngineHandlerContext.fireWrite(ProtonBuffer, Runnable)
void	handleWrite(EngineHandlerContext context, SASLEnvelope envelope)	Handles write of SaslPerformative either by directly writing it to the output target or by converting it to bytes and firing a write using the ProtonBuffer based API in EngineHandlerContext.fireWrite(ProtonBuffer, Runnable)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.qpid.protonj2.engine.EngineHandler

engineFailed, engineStarting, handleEngineStateChanged, handleRead, handlerRemoved, handleWrite

Constructor Detail

ProtonFrameLoggingHandler

public ProtonFrameLoggingHandler()

Method Detail

handlerAdded

public void handlerAdded(EngineHandlerContext context)

Description copied from interface: EngineHandler

Called when the handler is successfully added to the EnginePipeline and will later be initialized before use.

Specified by:

handlerAdded in interface EngineHandler

Parameters:

context - The context that is assigned to this handler.

handleRead

public void handleRead(EngineHandlerContext context,
                       HeaderEnvelope envelope)

Description copied from interface: EngineHandler

Handle the receipt of an incoming AMQP Header or SASL Header based on the current state of this handler.

Specified by:

handleRead in interface EngineHandler

Parameters:

context - The context for this handler which can be used to forward the event to the next handler

envelope - The AMQP Header envelope that wraps the received header instance.

handleRead

public void handleRead(EngineHandlerContext context,
                       SASLEnvelope envelope)

Description copied from interface: EngineHandler

Handle the receipt of an incoming SASL performative based on the current state of this handler.

Specified by:

handleRead in interface EngineHandler

Parameters:

context - The context for this handler which can be used to forward the event to the next handler

envelope - The SASL envelope that wraps the received SaslPerformative.

handleRead

public void handleRead(EngineHandlerContext context,
                       IncomingAMQPEnvelope envelope)

Description copied from interface: EngineHandler

Handle the receipt of an incoming AMQP envelope based on the current state of this handler.

Specified by:

handleRead in interface EngineHandler

Parameters:

context - The context for this handler which can be used to forward the event to the next handler

envelope - The AMQP envelope that wraps the received Performative.

handleWrite

public void handleWrite(EngineHandlerContext context,
                        HeaderEnvelope envelope)

Description copied from interface: EngineHandler

Handles write of AMQPHeader either by directly writing it to the output target or by converting it to bytes and firing a write using the ProtonBuffer based API in EngineHandlerContext.fireWrite(ProtonBuffer, Runnable)

Specified by:

handleWrite in interface EngineHandler

Parameters:

context - The EngineHandlerContext associated with this EngineHandler instance.

envelope - The HeaderEnvelope instance to write.

handleWrite

public void handleWrite(EngineHandlerContext context,
                        OutgoingAMQPEnvelope envelope)

Description copied from interface: EngineHandler

Handles write of AMQP performative envelope either by directly writing it to the output target or by converting it to bytes and firing a write using the ProtonBuffer based API in EngineHandlerContext.fireWrite(ProtonBuffer, Runnable)

Specified by:

handleWrite in interface EngineHandler

Parameters:

context - The EngineHandlerContext associated with this EngineHandler instance.

envelope - The OutgoingAMQPEnvelope instance to write.

handleWrite

public void handleWrite(EngineHandlerContext context,
                        SASLEnvelope envelope)

Description copied from interface: EngineHandler

Handles write of SaslPerformative either by directly writing it to the output target or by converting it to bytes and firing a write using the ProtonBuffer based API in EngineHandlerContext.fireWrite(ProtonBuffer, Runnable)

Specified by:

handleWrite in interface EngineHandler

Parameters:

context - The EngineHandlerContext associated with this EngineHandler instance.

envelope - The SASLEnvelope instance to write.