Package 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	Description
KAFKAInjectHandler(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)	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

KAFKAInjectHandler

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

Method Details

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