public class NatsInjectHandler extends Object
Constructor and Description |
---|
NatsInjectHandler(String injectingSeq,
String onErrorSeq,
boolean sequential,
org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
String contentType) |
Modifier and Type | Method and 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
|
public boolean invoke(Object object, String name, String replyTo, io.nats.client.Connection connection) throws org.apache.synapse.SynapseException
org.apache.synapse.SynapseException
Copyright © 2021 WSO2. All rights reserved.