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
All Methods Instance Methods Concrete Methods 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
-
-
-
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 interfaceInjectHandler
-
-