Adjust to Jackson3-backed implementation.

Signed-off-by: Olga Maciaszek-Sharma <[email protected]>

Author: OlgaMaciaszek

tests/samples-messaging-amqp/src/main/java/com/example/AmqpMessagingApplication.java

@@ -16,14 +16,14 @@
 
 package com.example;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
+import tools.jackson.databind.json.JsonMapper;
 
 import org.springframework.amqp.core.Exchange;
 import org.springframework.amqp.core.TopicExchange;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter;
-import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.amqp.support.converter.JacksonJsonMessageConverter;
 import org.springframework.amqp.support.converter.MessageConverter;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -40,7 +40,7 @@ public static void main(String[] args) {
 
 	@Bean
 	public MessageConverter messageConverter() {
-		final Jackson2JsonMessageConverter jsonMessageConverter = new Jackson2JsonMessageConverter(new ObjectMapper());
+		final JacksonJsonMessageConverter jsonMessageConverter = new JacksonJsonMessageConverter(new JsonMapper());
 		jsonMessageConverter.setCreateMessageIds(true);
 		final ContentTypeDelegatingMessageConverter messageConverter = new ContentTypeDelegatingMessageConverter(
 				jsonMessageConverter);

tests/samples-messaging-amqp/src/main/java/com/example/Issue178ListenerConfiguration.java

@@ -16,8 +16,7 @@
 
 package com.example;
 
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
+import tools.jackson.databind.ObjectMapper;
 
 import org.springframework.amqp.core.Binding;
 import org.springframework.amqp.core.BindingBuilder;
@@ -50,19 +49,13 @@ SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connec
 
 	@Bean
 	MessageListener exampleListener(final RabbitTemplate rabbitTemplate) {
-		return new MessageListener() {
-			public void onMessage(Message message) {
-				System.out.println("received: " + message);
-				try {
-					String payload = new ObjectMapper()
-						.writeValueAsString(new MyPojo("992e46d8-ab05-4a26-a740-6ef7b0daeab3", "CREATED"));
-					Message outputMessage = MessageBuilder.withBody(payload.getBytes()).build();
-					rabbitTemplate.send(issue178OutputExchange().getName(), "routingkey", outputMessage);
-				}
-				catch (JsonProcessingException e) {
-					throw new RuntimeException(e);
-				}
-			}
+		return message -> {
+			System.out.println("received: " + message);
+			String payload = new ObjectMapper()
+				.writeValueAsString(new MyPojo("992e46d8-ab05-4a26-a740-6ef7b0daeab3", "CREATED"));
+			Message outputMessage = MessageBuilder.withBody(payload.getBytes()).build();
+			rabbitTemplate.send(issue178OutputExchange().getName(), "routingkey", outputMessage);
+
 		};
 	}