提交粮情协议1

jiazx0107@163.com

2023-12-02 5bb3ad3944ff229baff1d8bb92caf55d816ee68b

 src/main/java/com/fzzy/mqtt/MqttConsumerConfig.java

@@ -67,8 +67,7 @@
        String[] topics = mqttProperties.getTopics().split(",");
        //topicList.toArray(topics);

        MqttPahoMessageDrivenChannelAdapter adapter =
                new MqttPahoMessageDrivenChannelAdapter(mqttProperties.getClientInId(), receiverMqttClientFactoryForSub(), topics);
        MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(mqttProperties.getClientInId(), receiverMqttClientFactoryForSub(), topics);
        adapter.setCompletionTimeout(mqttProperties.getCompletionTimeout());
        adapter.setConverter(new DefaultPahoMessageConverter());
        adapter.setQos(mqttProperties.getQos());
@@ -85,12 +84,6 @@
            public void handleMessage(Message<?> message) throws MessagingException {
                String topic = message.getHeaders().get("mqtt_receivedTopic").toString();
                String msg = message.getPayload().toString();

                // 这里可以处理接收的数据
                log.info("----------------------------收到订阅内容---------------------------");
                log.info("-----TOPIC-----{}", topic);
                log.info("-----Message-----{}", msg);

                onReceiveMqttService.onReceiveMessage(topic, msg);
            }
        };