Package com.rabbitmq.stream.codec

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 com.rabbitmq.stream.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(byte[] data)
Codec.EncodedMessage	encode(Message message)
MessageBuilder	messageBuilder()

Methods inherited from class java.lang.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(byte[] data)

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