Class KAFKAInjectHandler

  • All Implemented Interfaces:
    InjectHandler

    public class KAFKAInjectHandler
    extends Object
    implements InjectHandler
    KafkaInjectHandler uses to mediate the received Kafka message
    • Constructor Detail

      • KAFKAInjectHandler

        public KAFKAInjectHandler​(String injectingSeq,
                                  String onErrorSeq,
                                  boolean sequential,
                                  org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
                                  String contentType)
    • Method Detail

      • invoke

        public boolean invoke​(Object object,
                              String name)
        Determine the message builder to use, set the message payload to the message context and inject the message to the sequence
        Specified by:
        invoke in interface InjectHandler