Package com.rabbitmq.stream.codec

Class SwiftMqCodec

java.lang.Object
com.rabbitmq.stream.codec.SwiftMqCodec
All Implemented Interfaces:
Codec
public class SwiftMqCodec extends Object implements Codec

  • Constructor Details

    • SwiftMqCodec

      public SwiftMqCodec()

  • Method Details

    • messageBuilder

      public MessageBuilder messageBuilder()
      Specified by:
      messageBuilder in interface Codec

    • encode

      public Codec.EncodedMessage encode(Message message)
      Specified by:
      encode in interface Codec

    • convertToSwiftMqType

      protected static com.swiftmq.amqp.v100.types.AMQPType convertToSwiftMqType(Object value)

    • toSwiftMqTypeCode

      protected static int toSwiftMqTypeCode(Object value)

    • decode

      public Message decode(byte[] data)
      Specified by:
      decode in interface Codec

    • extractBody

      protected Object extractBody(com.swiftmq.amqp.v100.messaging.AMQPMessage amqpMessage)

    • createProperties

      protected Properties createProperties(com.swiftmq.amqp.v100.messaging.AMQPMessage amqpMessage)

    • createMessage

      protected Message createMessage(byte[] data)