rain
2024-08-21 2db1aa88e8ab53096a936163d686b90d8e056a99
src/main/java/com/dji/sample/component/rabbitmq/config/MqttMsgProxyProducer.java
@@ -1,4 +1,3 @@
/*
package com.dji.sample.component.rabbitmq.config;
import org.springframework.amqp.core.Message;
@@ -18,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(){
@@ -45,15 +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();
    }
}*/
}