package org.example.service;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

import java.util.Map;

@Component
@RocketMQMessageListener(topic = "seckill-order", consumerGroup = "seckill-consumer")
public class OrderConsumer implements RocketMQListener<Map> {

    @Override
    public void onMessage(Map msg) {
        System.out.println("收到订单：" + msg);
        // 后期写 DB
    }
}