Class CoreObjectMessageWrapper

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.converter.coreWrapper.CoreMessageWrapper
org.apache.activemq.artemis.protocol.amqp.converter.coreWrapper.CoreObjectMessageWrapper

public class CoreObjectMessageWrapper extends CoreMessageWrapper
  • Field Details

  • Constructor Details

    • CoreObjectMessageWrapper

      public CoreObjectMessageWrapper(ICoreMessage message)
  • Method Details

    • createAMQPSection

      public org.apache.qpid.proton.amqp.messaging.Section createAMQPSection(Map<org.apache.qpid.proton.amqp.Symbol, Object> maMap, org.apache.qpid.proton.amqp.messaging.Properties properties) throws ConversionException
      Overrides:
      createAMQPSection in class CoreMessageWrapper
      Throws:
      ConversionException
    • setSerializedForm

      public void setSerializedForm(org.apache.qpid.proton.amqp.Binary payload)
    • getSerializedForm

      public org.apache.qpid.proton.amqp.Binary getSerializedForm()
    • encode

      public void encode()
      Description copied from class: CoreMessageWrapper
      Encode the body into the internal message
      Overrides:
      encode in class CoreMessageWrapper
    • decode

      public void decode()
      Overrides:
      decode in class CoreMessageWrapper