From 98c8e73c57f8f76e5720a066f155ebfff2a7cc5f Mon Sep 17 00:00:00 2001
From: rain <167982779@qq.com>
Date: Thu, 18 Apr 2024 20:05:48 +0800
Subject: [PATCH] 修改DB成果展示入库失败，增加TbfjEntity表的字段，无对应字段默认0.
---
src/main/java/com/dji/sample/component/mqtt/config/MqttInboundConfiguration.java | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/dji/sample/component/mqtt/config/MqttInboundConfiguration.java b/src/main/java/com/dji/sample/component/mqtt/config/MqttInboundConfiguration.java
index 3964aaf..65c5e67 100644
--- a/src/main/java/com/dji/sample/component/mqtt/config/MqttInboundConfiguration.java
+++ b/src/main/java/com/dji/sample/component/mqtt/config/MqttInboundConfiguration.java
@@ -1,6 +1,7 @@
package com.dji.sample.component.mqtt.config;
import com.dji.sample.component.mqtt.model.ChannelName;
+import com.dji.sample.component.mqtt.model.MqttClientOptions;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
@@ -29,9 +30,6 @@
public class MqttInboundConfiguration {
@Autowired
- private MqttConfiguration mqttConfiguration;
-
- @Autowired
private MqttPahoClientFactory mqttClientFactory;
@Resource(name = ChannelName.INBOUND)
@@ -43,9 +41,10 @@
*/
@Bean(name = "adapter")
public MessageProducerSupport mqttInbound() {
+ MqttClientOptions options = MqttConfiguration.getBasicClientOptions();
MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(
- mqttConfiguration.getClientId() + "_consumer_" + System.currentTimeMillis(),
- mqttClientFactory, mqttConfiguration.getInboundTopic().split(","));
+ options.getClientId() + "_consumer_" + System.currentTimeMillis(),
+ mqttClientFactory, options.getInboundTopic().split(","));
DefaultPahoMessageConverter converter = new DefaultPahoMessageConverter();
// use byte types uniformly
converter.setPayloadAsBytes(true);
@@ -57,6 +56,7 @@
/**
* Define a default channel to handle messages that have no effect.
+ * 定义默认通道处理无效消息
* @return
*/
@Bean
--
Gitblit v1.9.3