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 Description RabbitMQInjectHandler(String injectingSeq, String onErrorSeq, boolean sequential, org.apache.synapse.core.SynapseEnvironment synapseEnvironment)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.
-
-
-
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 propertiesbody
- the message bodyinboundName
- Inbound Name- Returns:
- delivery status of the message
-
-