public class RabbitMQInjectHandler extends Object
Constructor and Description |
---|
RabbitMQInjectHandler(String injectingSeq,
String onErrorSeq,
boolean sequential,
org.apache.synapse.core.SynapseEnvironment synapseEnvironment) |
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.
|
public AcknowledgementMode onMessage(com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body, String inboundName)
properties
- the AMQP basic propertiesbody
- the message bodyinboundName
- Inbound NameCopyright © 2022 WSO2. All rights reserved.