Update ListenerConfig.java

JavaCodeMing · JavaCodeMing · commit 374298774c54 · 2020-01-02T13:00:16.000+08:00
diff --git a/Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/config/ListenerConfig.java b/Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/config/ListenerConfig.java
@@ -41,19 +41,18 @@ public RabbitListenerContainerFactory workListenerFactory(ConnectionFactory conn
 
     @Bean("jasonTemplate")
     public RabbitTemplate jasonRabbitTemplate(ConnectionFactory connectionFactory) {
-        Jackson2JsonMessageConverter messageConverter =
-                new Jackson2JsonMessageConverter();
         RabbitTemplate rabbitTemplate = new RabbitTemplate();
         rabbitTemplate.setConnectionFactory(connectionFactory);
-        //设置转化类
-        rabbitTemplate.setMessageConverter(messageConverter);
+        //设置消息发送时的消息转化类
+        rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
         return rabbitTemplate;
     }
 
     @Bean("jsonListenerFactory")
     public RabbitListenerContainerFactory jsonListenerFactory(ConnectionFactory connectionFactory){
         SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
         factory.setConnectionFactory(connectionFactory);
+        //设置消费者接收时的消息转化类
         factory.setMessageConverter(new Jackson2JsonMessageConverter());
         return factory;
     }
