public class ConsoleConsumer extends Object
| 限定符和类型 | 字段和说明 |
|---|---|
protected static org.slf4j.Logger |
logger |
| 构造器和说明 |
|---|
ConsoleConsumer() |
| 限定符和类型 | 方法和说明 |
|---|---|
protected static io.openmessaging.consumer.Consumer |
buildConsumer(ConsoleConsumerConfig config) |
static void |
main(String[] args) |
protected static void |
run(io.openmessaging.consumer.Consumer consumer,
ConsoleConsumerConfig config) |
public static void main(String[] args)
protected static io.openmessaging.consumer.Consumer buildConsumer(ConsoleConsumerConfig config)
protected static void run(io.openmessaging.consumer.Consumer consumer,
ConsoleConsumerConfig config)
Copyright © 2020 Joyqueue Community. All rights reserved.