| 程序包 | 说明 |
|---|---|
| com.github.panhongan.util.kafka.handler |
| 构造器和说明 |
|---|
InnerMessageProcessor(AbstractMessageHandler handler,
ArrayBlockingQueue<com.github.panhongan.util.kafka.handler.KafkaMessageWorkflow.Message> queue,
MessageKafkaWriter kafka_writer) |
KafkaMessageWorkflow(AbstractMessageHandler handler,
MessageKafkaWriter kafka_writer,
KafkaMessageServiceConfig config) |
Copyright © 2017. All rights reserved.