zhang
2026-03-24 a2359cd94c82ad61bc32a24bf1d25fc0f9c7cb68
zy-acs-gateway/src/main/java/com/zy/acs/gateway/handler/AgvPackageServerHandler.java
@@ -17,6 +17,7 @@
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
/**
@@ -36,6 +37,9 @@
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Value("${spring.rabbitmq.enable}")
    private Boolean flag;
    @Override
@@ -247,7 +251,7 @@
    }
    public void saveLogToMq(String topic_exchange, String routingKey, DeviceMessage message) {
        if (rabbitTemplate.isRunning()) {
        if (flag && rabbitTemplate.isRunning()) {
            // 写入队列
            rabbitTemplate.convertAndSend(topic_exchange, routingKey, message);
        } else {