package com.qianwen.smartman.modules.cps.message.producer;

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import com.qianwen.smartman.common.constant.WorkstationConstant;
import com.qianwen.smartman.modules.cps.dto.WorkstationCreateMessageDTO;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Component;

@Component
public class InsertWorkstationProducer {
    private final RocketMQTemplate rocketMQTemplate;

    public InsertWorkstationProducer(final RocketMQTemplate rocketMQTemplate) {
        this.rocketMQTemplate = rocketMQTemplate;
    }

    public void sendInsertWorkstationMessage(WorkstationCreateMessageDTO dto) {
        this.rocketMQTemplate.syncSend(WorkstationConstant.WORKSTATION_CREATE_TOPIC, MessageBuilder.withPayload(dto).build());
    }
}