11 lines
375 B
Plaintext
11 lines
375 B
Plaintext
package demo.mq;
|
|
|
|
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
|
import org.apache.rocketmq.spring.core.RocketMQListener;
|
|
|
|
@RocketMQMessageListener(topic = DutyImNoticeProducer.MQ_TOPIC, consumerGroup = "duty-im-group")
|
|
public class DutyImNoticeConsumer implements RocketMQListener<DutyImNotice> {
|
|
public void onMessage(DutyImNotice message) {
|
|
}
|
|
}
|