Class RabbitMQInjectHandler


  • public class RabbitMQInjectHandler
    extends Object
    The received messages will be injected into the sequence for the mediation.
    • Constructor Detail

      • RabbitMQInjectHandler

        public RabbitMQInjectHandler​(String injectingSeq,
                                     String onErrorSeq,
                                     boolean sequential,
                                     org.apache.synapse.core.SynapseEnvironment synapseEnvironment)
    • Method Detail

      • onMessage

        public AcknowledgementMode onMessage​(com.rabbitmq.client.AMQP.BasicProperties properties,
                                             byte[] body,
                                             String inboundName)
        Determine the message builder to use, set the message payload to the message context and inject the message.
        Parameters:
        properties - the AMQP basic properties
        body - the message body
        inboundName - Inbound Name
        Returns:
        delivery status of the message