Class NatsInjectHandler


  • public class NatsInjectHandler
    extends Object
    Inject handler to inject NATS message into the sequence.
    • Constructor Detail

      • NatsInjectHandler

        public NatsInjectHandler​(String injectingSeq,
                                 String onErrorSeq,
                                 boolean sequential,
                                 org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
                                 String contentType)
    • 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