package com.dy.pipIrrApp.workOrder;
|
|
import org.apache.rocketmq.spring.annotation.ConsumeMode;
|
import org.apache.rocketmq.spring.annotation.MessageModel;
|
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
import org.apache.rocketmq.spring.core.RocketMQListener;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* @author ZhuBaoMin
|
* @date 2024-11-04 11:00
|
* @LastEditTime 2024-11-04 11:00
|
* @Description
|
*/
|
|
@Component
|
@RocketMQMessageListener(
|
topic = "workOrder",
|
consumerGroup = "consumer_group",
|
selectorExpression = "*",
|
messageModel = MessageModel.CLUSTERING,
|
consumeMode = ConsumeMode.CONCURRENTLY
|
)
|
public class ConsumerListener implements RocketMQListener<String> {
|
@Override
|
public void onMessage(String message) {
|
System.out.println("ConsumerListener receive message: " + message);
|
}
|
}
|
