Class NatsInjectHandler
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.protocol.nats.NatsInjectHandler
-
public class NatsInjectHandler extends Object
Inject handler to inject NATS message into the sequence.
-
-
Constructor Summary
Constructors Constructor Description NatsInjectHandler(String injectingSeq, String onErrorSeq, boolean sequential, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, String contentType)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
invoke(Object object, String name, String replyTo, io.nats.client.Connection connection)
Determine the message builder to use, set the message payload to the message context and inject the message to the sequence
-
-
-
Method Detail
-
invoke
public boolean invoke(Object object, String name, String replyTo, io.nats.client.Connection connection) throws org.apache.synapse.SynapseException
Determine the message builder to use, set the message payload to the message context and inject the message to the sequence- Throws:
org.apache.synapse.SynapseException
-
-