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
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/message/producer/InsertWorkstationProducer.class */
|
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());
|
}
|
}
|
