Uses of Interface
org.wso2.carbon.inbound.endpoint.protocol.kafka.InjectHandler
-
Packages that use InjectHandler Package Description org.wso2.carbon.inbound.endpoint.protocol.kafka -
-
Uses of InjectHandler in org.wso2.carbon.inbound.endpoint.protocol.kafka
Classes in org.wso2.carbon.inbound.endpoint.protocol.kafka that implement InjectHandler Modifier and Type Class Description class
KAFKAInjectHandler
KafkaInjectHandler uses to mediate the received Kafka messageFields in org.wso2.carbon.inbound.endpoint.protocol.kafka declared as InjectHandler Modifier and Type Field Description protected InjectHandler
AbstractKafkaMessageListener. injectHandler
Methods in org.wso2.carbon.inbound.endpoint.protocol.kafka with parameters of type InjectHandler Modifier and Type Method Description void
KAFKAPollingConsumer. registerHandler(InjectHandler processingHandler)
Register a handler to implement injection of the retrieved messageConstructors in org.wso2.carbon.inbound.endpoint.protocol.kafka with parameters of type InjectHandler Constructor Description KAFKAMessageListener(int threadCount, List<String> topics, Properties kafkaProperties, InjectHandler injectHandler)
SimpleKafkaMessageListener(Properties kafkaProperties, InjectHandler injectHandler)
-