Class QpidProtonCodec

java.lang.Object

com.rabbitmq.stream.codec.QpidProtonCodec

All Implemented Interfaces:

Codec

public class QpidProtonCodec
extends Object
implements Codec

Nested Class Summary

Nested classes/interfaces inherited from interface Codec

Codec.EncodedMessage

Constructor Summary

Constructors

Constructor	Description
QpidProtonCodec()

Method Summary

Modifier and Type	Method	Description
protected Object	convertToQpidType(Object value)
protected static Properties	createProperties(org.apache.qpid.proton.message.Message message)
Message	decode(ByteBuf buf, int length)
Codec.EncodedMessage	encode(Message message)
MessageBuilder	messageBuilder()

Methods inherited from class Object

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

Constructor Details

QpidProtonCodec

public QpidProtonCodec()

Method Details

encode

public Codec.EncodedMessage encode(Message message)

Specified by:

encode in interface Codec

decode

public Message decode(ByteBuf buf,
 int length)

Specified by:

decode in interface Codec

createProperties

protected static Properties createProperties(org.apache.qpid.proton.message.Message message)

convertToQpidType

protected Object convertToQpidType(Object value)

messageBuilder

public MessageBuilder messageBuilder()

Specified by:

messageBuilder in interface Codec