Package org.wso2.carbon.inbound.endpoint.protocol.nats

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

NatsInjectHandler

public NatsInjectHandler(String injectingSeq,
 String onErrorSeq,
 boolean sequential,
 org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
 String contentType)

Method Details

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