Package org.apache.qpid.protonj2.codec

Class PerformativeEncoder

java.lang.Object

org.apache.qpid.protonj2.codec.PerformativeEncoder

All Implemented Interfaces:

Performative.PerformativeHandler<Encoder>

public final class PerformativeEncoder
extends Object
implements Performative.PerformativeHandler<Encoder>

AMQP Performative type specific encoder that uses any Encoder to cache the specific type encoders for various section types and use them directly instead of looking them up via calls to Encoder.writeObject(org.apache.qpid.protonj2.buffer.ProtonBuffer, EncoderState, Object)

Constructor Summary

Constructors

Constructor	Description
PerformativeEncoder(Encoder encoder)

Method Summary

Modifier and Type	Method	Description
Encoder	getEncoder()
EncoderState	getEncoderState()
void	handleAttach(Attach attach, ProtonBuffer target, int channel, Encoder encoder)
void	handleBegin(Begin begin, ProtonBuffer target, int channel, Encoder encoder)
void	handleClose(Close close, ProtonBuffer target, int channel, Encoder encoder)
void	handleDetach(Detach detach, ProtonBuffer target, int channel, Encoder encoder)
void	handleDisposition(Disposition disposition, ProtonBuffer target, int channel, Encoder encoder)
void	handleEnd(End end, ProtonBuffer target, int channel, Encoder encoder)
void	handleFlow(Flow flow, ProtonBuffer target, int channel, Encoder encoder)
void	handleOpen(Open open, ProtonBuffer target, int channel, Encoder encoder)
void	handleTransfer(Transfer transfer, ProtonBuffer target, int channel, Encoder encoder)

Methods inherited from class java.lang.Object

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

Constructor Detail

PerformativeEncoder

public PerformativeEncoder(Encoder encoder)

Method Detail

getEncoder

public Encoder getEncoder()

getEncoderState

public EncoderState getEncoderState()

handleOpen

public void handleOpen(Open open,
                       ProtonBuffer target,
                       int channel,
                       Encoder encoder)

Specified by:

handleOpen in interface Performative.PerformativeHandler<Encoder>

handleBegin

public void handleBegin(Begin begin,
                        ProtonBuffer target,
                        int channel,
                        Encoder encoder)

Specified by:

handleBegin in interface Performative.PerformativeHandler<Encoder>

handleAttach

public void handleAttach(Attach attach,
                         ProtonBuffer target,
                         int channel,
                         Encoder encoder)

Specified by:

handleAttach in interface Performative.PerformativeHandler<Encoder>

handleFlow

public void handleFlow(Flow flow,
                       ProtonBuffer target,
                       int channel,
                       Encoder encoder)

Specified by:

handleFlow in interface Performative.PerformativeHandler<Encoder>

handleTransfer

public void handleTransfer(Transfer transfer,
                           ProtonBuffer target,
                           int channel,
                           Encoder encoder)

Specified by:

handleTransfer in interface Performative.PerformativeHandler<Encoder>

handleDisposition

public void handleDisposition(Disposition disposition,
                              ProtonBuffer target,
                              int channel,
                              Encoder encoder)

Specified by:

handleDisposition in interface Performative.PerformativeHandler<Encoder>

handleDetach

public void handleDetach(Detach detach,
                         ProtonBuffer target,
                         int channel,
                         Encoder encoder)

Specified by:

handleDetach in interface Performative.PerformativeHandler<Encoder>

handleEnd

public void handleEnd(End end,
                      ProtonBuffer target,
                      int channel,
                      Encoder encoder)

Specified by:

handleEnd in interface Performative.PerformativeHandler<Encoder>

handleClose

public void handleClose(Close close,
                        ProtonBuffer target,
                        int channel,
                        Encoder encoder)

Specified by:

handleClose in interface Performative.PerformativeHandler<Encoder>