org.wso2.carbon.inbound.endpoint.protocol.rabbitmq

Class RabbitMQInjectHandler

java.lang.Object

org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQInjectHandler

public class RabbitMQInjectHandler
extends Object

The received messages will be injected into the sequence for the mediation.

Constructor Summary

Constructors

Constructor and Description
RabbitMQInjectHandler(String injectingSeq, String onErrorSeq, boolean sequential, org.apache.synapse.core.SynapseEnvironment synapseEnvironment)

Method Summary

Modifier and Type	Method and Description
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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