File tree Expand file tree Collapse file tree
spring-batch-samples/src/test/java/org/springframework/batch/samples/amqp Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2929import org .springframework .amqp .rabbit .connection .CachingConnectionFactory ;
3030import org .springframework .amqp .rabbit .core .RabbitAdmin ;
3131import org .springframework .amqp .rabbit .core .RabbitTemplate ;
32- import org .springframework .amqp .support .converter .Jackson2JsonMessageConverter ;
32+ import org .springframework .amqp .support .converter .JacksonJsonMessageConverter ;
3333import org .springframework .batch .core .job .Job ;
3434import org .springframework .batch .core .job .parameters .JobParameters ;
3535import org .springframework .batch .core .repository .JobRepository ;
@@ -132,7 +132,7 @@ public CachingConnectionFactory connectionFactory() {
132132 @ Bean
133133 public AmqpTemplate rabbitOutputTemplate (CachingConnectionFactory connectionFactory ) {
134134 RabbitTemplate template = new RabbitTemplate (connectionFactory );
135- template .setMessageConverter (new Jackson2JsonMessageConverter ());
135+ template .setMessageConverter (new JacksonJsonMessageConverter ());
136136 template .setExchange (EXCHANGE_NAME );
137137 return template ;
138138 }
@@ -143,7 +143,7 @@ public AmqpTemplate rabbitOutputTemplate(CachingConnectionFactory connectionFact
143143 @ Bean
144144 public RabbitTemplate rabbitInputTemplate (CachingConnectionFactory connectionFactory ) {
145145 RabbitTemplate template = new RabbitTemplate (connectionFactory );
146- template .setMessageConverter (new Jackson2JsonMessageConverter ());
146+ template .setMessageConverter (new JacksonJsonMessageConverter ());
147147 template .setDefaultReceiveQueue (QUEUE_NAME );
148148 return template ;
149149 }
You can’t perform that action at this time.
0 commit comments