rain
2024-06-14 8d9a2d656e4ae007590c622e5f7c228adacdca49
src/main/java/com/dji/sample/component/rabbitmq/config/MqttMsgProxyProducer.java
@@ -17,7 +17,7 @@
    @Autowired
    private RabbitTemplate rabbitTemplate;
    private static final String EXCHANGE_NAME = "mshub.uav";
    private static final String EXCHANGE_NAME = "drone";
    @Bean(EXCHANGE_NAME)
    public TopicExchange createExchange(){
@@ -44,13 +44,21 @@
        rabbitTemplate.send(EXCHANGE_NAME,routingKey, message);
    }
    /**
    public void publish(String routingKey, byte[] content) {
        Message message = MessageBuilder.withBody(content)
                .setExpiration("1000")
                .build();
        rabbitTemplate.send(EXCHANGE_NAME,routingKey, message);
    }
   /* *
     * 使用json序列化机制,进行消息转换
     * @return -
     */
     * @return -*/
    @Bean
    public MessageConverter jackson2MessageConverter() {
        return new Jackson2JsonMessageConverter();
    }
}
}