图斑

rain

2024-03-22 51e59e6608f2ad75b86e2ba6c617d1e7b3b85785

 src/main/java/com/dji/sample/component/mqtt/config/MqttOutboundConfiguration.java

@@ -33,7 +33,7 @@
    @ServiceActivator(inputChannel = ChannelName.OUTBOUND)
    public MessageHandler mqttOutbound() {
        MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler(
                mqttConfiguration.getClientId() + "_producer_" + System.currentTimeMillis(),
                MqttConfiguration.getBasicClientOptions().getClientId() + "_producer_" + System.currentTimeMillis(),
                mqttClientFactory);
        DefaultPahoMessageConverter converter = new DefaultPahoMessageConverter();
        // use byte types uniformly