Uses of Interface
org.wso2.carbon.inbound.endpoint.protocol.kafka.InjectHandler
Packages that use InjectHandler
-
Uses of InjectHandler in org.wso2.carbon.inbound.endpoint.protocol.kafka
Classes in org.wso2.carbon.inbound.endpoint.protocol.kafka that implement InjectHandlerModifier and TypeClassDescriptionclassKafkaInjectHandler uses to mediate the received Kafka messageFields in org.wso2.carbon.inbound.endpoint.protocol.kafka declared as InjectHandlerModifier and TypeFieldDescriptionprotected InjectHandlerAbstractKafkaMessageListener.injectHandlerMethods in org.wso2.carbon.inbound.endpoint.protocol.kafka with parameters of type InjectHandlerModifier and TypeMethodDescriptionvoidKAFKAPollingConsumer.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 InjectHandlerModifierConstructorDescriptionKAFKAMessageListener(int threadCount, List<String> topics, Properties kafkaProperties, InjectHandler injectHandler) SimpleKafkaMessageListener(Properties kafkaProperties, InjectHandler injectHandler)