1

zc

2026-04-11 ba63be1a0daee0078f1d93fd355c7d0e94c9f931

1

 zy-acs-gateway/src/main/java/com/zy/acs/gateway/handler/AgvPackageServerHandler.java

@@ -251,7 +251,7 @@
    }

    public void saveLogToMq(String topic_exchange, String routingKey, DeviceMessage message) {
        if (flag && rabbitTemplate.isRunning()) {
        if (flag) {
            // 写入队列
            rabbitTemplate.convertAndSend(topic_exchange, routingKey, message);
        } else {

 zy-acs-gateway/src/main/java/com/zy/acs/gateway/listen/MessageListener.java

@@ -59,7 +59,7 @@
                    if (!Cools.isEmpty(protocol.getAgvNo())) {
                        AgvPackage agvPackage = ProtocolUtils.installDownProtocol(protocol);
                        publisher.publish(agvPackage);
                        if (flag && rabbitTemplate.isRunning()) {
                        if (flag) {
                            // 写入队列
                            rabbitTemplate.convertAndSend(RabbitmqConstant.TOPIC_EXCHANGE, RabbitmqConstant.ROUTING_KEY_DOWN.replaceFirst(RabbitmqConstant.SPILT_REGEX, protocol.getAgvNo()).replaceFirst(RabbitmqConstant.SPILT_REGEX, agvPackage.getHeader().getProtocolType().name()),new DeviceMessage(agvPackage.getSourceHexStr()));
                        } else {

 zy-acs-gateway/src/main/resources/application.yml

@@ -11,7 +11,7 @@
    password: xltys1995

  rabbitmq:
    enable: false
    enable: true
    host: localhost
    port: 5672
    username: root