AmqpCoreConverter (ActiveMQ Artemis AMQP Protocol 2.44.0 API)

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.converter.AmqpCoreConverter

public class AmqpCoreConverter extends Object

This class was created just to separate concerns on AMQPConverter. For better organization of the code.

Constructor Summary

Constructors

Constructor

Description

AmqpCoreConverter()
Method Summary

Modifier and Type

Method

Description

protected static CoreMessageWrapper

processHeader(CoreMessageWrapper jms, org.apache.qpid.proton.amqp.messaging.Header header)

protected static CoreMessageWrapper

processMessageAnnotations(CoreMessageWrapper jms, org.apache.qpid.proton.amqp.messaging.MessageAnnotations annotations)

static ICoreMessage

toCore(AMQPMessage message, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools)

static ICoreMessage

toCore(AMQPMessage message, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools, org.apache.qpid.proton.amqp.messaging.Header header, org.apache.qpid.proton.amqp.messaging.MessageAnnotations annotations, org.apache.qpid.proton.amqp.messaging.Properties properties, org.apache.qpid.proton.amqp.messaging.ApplicationProperties applicationProperties, org.apache.qpid.proton.amqp.messaging.Section body, org.apache.qpid.proton.amqp.messaging.Footer footer)

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- AmqpCoreConverter
  
  public AmqpCoreConverter()
Method Details
- toCore
  
  public static ICoreMessage toCore(AMQPMessage message, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools) throws Exception
  
  Throws:
  
  Exception
- toCore
  
  public static ICoreMessage toCore(AMQPMessage message, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools, org.apache.qpid.proton.amqp.messaging.Header header, org.apache.qpid.proton.amqp.messaging.MessageAnnotations annotations, org.apache.qpid.proton.amqp.messaging.Properties properties, org.apache.qpid.proton.amqp.messaging.ApplicationProperties applicationProperties, org.apache.qpid.proton.amqp.messaging.Section body, org.apache.qpid.proton.amqp.messaging.Footer footer) throws ConversionException
  
  Throws:
  
  ConversionException
- processHeader
  
  protected static CoreMessageWrapper processHeader(CoreMessageWrapper jms, org.apache.qpid.proton.amqp.messaging.Header header) throws ConversionException
  
  Throws:
  
  ConversionException
- processMessageAnnotations
  
  protected static CoreMessageWrapper processMessageAnnotations(CoreMessageWrapper jms, org.apache.qpid.proton.amqp.messaging.MessageAnnotations annotations)