src/main/java/com/dji/sample/component/rabbitmq/config/MqttMsgProxyProducer.java
@@ -44,6 +44,13 @@ 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 -*/