blame | history | patch | commit | commitdiff | ignore whitespace
rain
2024-04-07 1982a4f0aea16e109d3f30ddc20c2458ea0f6f31 
 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