org.wso2.carbon.inbound.endpoint.protocol.kafka

Class KAFKAInjectHandler

java.lang.Object

org.wso2.carbon.inbound.endpoint.protocol.kafka.KAFKAInjectHandler

All Implemented Interfaces:

InjectHandler

public class KAFKAInjectHandler
extends Object
implements InjectHandler

KafkaInjectHandler uses to mediate the received Kafka message

Constructor Summary

Constructors

Constructor and Description
KAFKAInjectHandler(String injectingSeq, String onErrorSeq, boolean sequential, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, String contentType)

Method Summary

Methods

Modifier and Type	Method and Description
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

Methods inherited from class java.lang.Object

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

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