Class AMQPMessageBrokerAccessor

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessageBrokerAccessor
public class AMQPMessageBrokerAccessor extends Object
Warning: do not use this class outside of the broker implementation. This is exposing package methods on this package that are not meant to be used on user's application.

  • Constructor Details

    • AMQPMessageBrokerAccessor

      public AMQPMessageBrokerAccessor()

  • Method Details

    • getDeliveryAnnotationProperty

      public static Object getDeliveryAnnotationProperty(AMQPMessage message, org.apache.qpid.proton.amqp.Symbol symbol)
      Warning: this is a method specific to the broker. Do not use it on user's application.

    • getMessageAnnotationProperty

      public static Object getMessageAnnotationProperty(AMQPMessage message, org.apache.qpid.proton.amqp.Symbol symbol)
      Warning: this is a method specific to the broker. Do not use it on user's application.

    • getMessageAnnotationAckReason

      public static org.apache.activemq.artemis.core.server.impl.AckReason getMessageAnnotationAckReason(AMQPMessage message)

    • getCurrentHeader

      public static org.apache.qpid.proton.amqp.messaging.Header getCurrentHeader(AMQPMessage message)
      Warning: this is a method specific to the broker. Do not use it on user's application.

    • getDecodedApplicationProperties

      public static org.apache.qpid.proton.amqp.messaging.ApplicationProperties getDecodedApplicationProperties(AMQPMessage message)
      Warning: this is a method specific to the broker. Do not use it on user's application.

    • getRemainingBodyPosition

      public static int getRemainingBodyPosition(AMQPMessage message)
      Warning: this is a method specific to the broker. Do not use it on user's application.

    • getCurrentProperties

      public static org.apache.qpid.proton.amqp.messaging.Properties getCurrentProperties(AMQPMessage message)
      Warning: this is a method specific to the broker. Do not use it on user's application.

    • getDecodedMessageAnnotations

      public static org.apache.qpid.proton.amqp.messaging.MessageAnnotations getDecodedMessageAnnotations(AMQPMessage message)