| | |
| | | @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(){ |
| | |
| | | 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(); |
| | | } |
| | | |
| | | } |
| | | } |