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);
    }
}