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 |
---|---|
org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.States |
invokeAndReturnAckState(RabbitMQMessage message,
String inboundName)
Determine the message builder to use, set the message payload to the message context and
inject the message.
|
public org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.States invokeAndReturnAckState(RabbitMQMessage message, String inboundName)
message
- RabbitMQ message consumedinboundName
- Inbound NameCopyright © 2020 WSO2. All rights reserved.