程序包 | 说明 |
---|---|
wang.bigbird.domain.framework.data.rocketmq.service | |
wang.bigbird.domain.framework.data.rocketmq.service.impl |
限定符和类型 | 方法和说明 |
---|---|
<T> void |
RocketmqConsumerService.consume(String consumerGroupName,
String topic,
String tag,
org.apache.rocketmq.common.protocol.heartbeat.MessageModel messageModel,
Class<T> messageClass,
RocketmqConsumerHandler<T> handler)
消费消息,消费者一旦创建,不能更改,因此每次调用该方法均会新建一个消费者
|
限定符和类型 | 方法和说明 |
---|---|
<T> void |
RocketmqConsumerServiceImpl.consume(String consumerGroupName,
String topic,
String tag,
org.apache.rocketmq.common.protocol.heartbeat.MessageModel messageModel,
Class<T> messageClass,
RocketmqConsumerHandler<T> handler) |