Missing Jackson Module when using annotation @SqsListener

[bauna]

I'm writing a test using LocalStack with TestContainers to verify that a message was sent to a SQS queue.
When I check received messages using a SQS Template, the message payload is deserialized properly, the SQS Template snippet.

Although when I try to use a class to receive the message, with a method annotated with @SqsListener. It fails to deserialize the same payload class, the class snippet
Here is the relevant section of the stacktrace:

14:30:36 [sdk-async-response-2-16] ERROR [] i.a.c.s.l.s.AbstractMessageConvertingMessageSource: Error converting message Message(MessageId=e93fa68e-7bf8-4d34-af9b-12000bc34738, ReceiptHandle=MzUyMDA5NzUtYjZiOC00YTU2LTkwZDEtMDZiNjBkOThhNTBmIGFybjphd3M6c3FzOnVzLWVhc3QtMTowMDAwMDAwMDAwMDA6aHVtYW5kLXdlYmhvb2tzLWV4dGVybmFsLmZpZm8gZTkzZmE2OGUtN2JmOC00ZDM0LWFmOWItMTIwMDBiYzM0NzM4IDE3NTE5OTU4MzIuNjM3OTkyNg==, MD5OfBody=f370b5e9f5ea3a0506ba4edba66ea220, Body={"id":"01JZNHDBD46F3PCBV1WYBX9XVT","instanceId":1,"namespace":"conversations","metadata":{"requestId":"01JZNHDB0G4DRYERW1SFXQQFHG"},"topic":"CHATS_V2_NEW_CHAT","payload":{"data":"eyJodV9kYXRhIjp7InZlcnNpb24iOjAsInBvc2l0aW9uIjowfSwidHlwZSI6ImltX2NyZWF0ZWQiLCJzdWJ0eXBlIjoiIiwiY2hhbm5lbCI6IjAxSlpOSERCRDQ2RjNQQ0JWMVdZQlg5WFZUIiwidXNlciI6IjIiLCJ1c2VybmFtZSI6Im5hbWUyIGxhc3ROYW1lMiIsInRzIjoiMDFKWk5IREJENDZGM1BDQlYxV1lCWDlYVlQiLCJtZXRhZGF0YSI6eyJldmVudF9wYXlsb2FkIjp7InVzZXJzIjpbMiwzXX19fQ==","contentType":"application/json"},"timestamp":"2025-07-08T17:30:21.502396Z","version":1}, Attributes={ApproximateReceiveCount=1, SentTimestamp=1751995832635, SequenceNumber=15049529507847340033, MessageGroupId=01JZNHDBD46F3PCBV1WYBX9XVT, SenderId=000000000000, MessageDeduplicationId=01JZNHDBD46F3PCBV1WYBX9XVT, ApproximateFirstReceiveTimestamp=1751995832637}, MD5OfMessageAttributes=69dafdc7c503aafe46f8f091f4e560f6, MessageAttributes={contentType=MessageAttributeValue(StringValue=application/json, DataType=String), JavaType=MessageAttributeValue(StringValue=co.humand.webhooks.core.events.SerializedEvent, DataType=String), requestId=MessageAttributeValue(StringValue=01JZNHDB0G4DRYERW1SFXQQFHG, DataType=String)}), ignoring.
org.springframework.messaging.converter.MessageConversionException: Could not read JSON: Java 8 date/time type `java.time.Instant` not supported by default: add Module "com.fasterxml.jackson.datatype:jackson-datatype-jsr310" to enable handling (or disable `MapperFeature.REQUIRE_HANDLERS_FOR_JAVA8_TIMES`)
 at [Source: REDACTED (`StreamReadFeature.INCLUDE_SOURCE_IN_LOCATION` disabled); line: 1, column: 536] (through reference chain: co.humand.webhooks.core.events.SerializedEvent["timestamp"])
	at org.springframework.messaging.converter.MappingJackson2MessageConverter.convertFromInternal(MappingJackson2MessageConverter.java:258)
	at org.springframework.messaging.converter.AbstractMessageConverter.fromMessage(AbstractMessageConverter.java:183)

Versions:
springboot: 3.5.3
awsspring: 3.3.1

Payload Record

public record SerializedEvent(String id, Long instanceId, 
    String namespace, Map<String, String> metadata, 
    String topic, SerializedPayload payload, 
    Instant timestamp, Long version) {}

public record SerializedPayload(String data, String contentType) {}

Annotated Class

@Component
public class TestListener {
    public static final Logger LOGGER = LoggerFactory.getLogger(TestListener.class);
    public static final List<SerializedEvent> events = new CopyOnWriteArrayList<>();

    public void clear() {
        LOGGER.info("Clearing events");
        events.clear();
    }

    @SqsListener(queueNames = "webhooks-external.fifo")
    public void add(SerializedEvent event) {
        LOGGER.info("Received event: {}", event);
        events.add(event);
    }

    public List<SerializedEvent> getEvents() {
        return List.copyOf(events);
    }
}

SQSTemplate

   class ConversationPostMessagesWebhookTest extends BaseMockMvcTest {
    @Autowired
    private SqsTemplate sqsTemplate;

    @Autowired
    private EventQueuesProperties eventQueuesProperties;

    private Community community;
    private SendMessageCommand sendMessageCommand;

    @BeforeEach
    void createCommunity() {
        community = communityFactory.newCommunity();
        sendMessageCommand = new SendMessageCommand(this);
    }

    @Test
    void whenSendingAMessage_aWebhookEventIsSent() {
        User user = community.user2();
        var conversationResponse = conversationOpen(user, CREATED);
        HuChatPostMessageResponse messageResponse = sendMessageCommand.sendMessage(
                user, conversationResponse.getChannel().getId(), "a message");

        String newMessageEventTs = messageResponse.getTs().toString();
        await().untilAsserted(() -> {
            Event event =
                    sqsTemplate.receiveMany(eventQueuesProperties.publicWebhookQueue(), SerializedEvent.class).stream()
                            .map(Message::getPayload)
                            .map(SerializedEvent::toEvent)
                            .filter(e -> newMessageEventTs.equals(e.getId().value()))
                            .findAny()
                            .orElseThrow();
                            

[tomazfernandes]

Hi @bauna,

Would you be able to provide a minimal reproducible example that reproduces the issue?

What I can affirm without further context is that by default both SqsTemplate and SqsMessageListenerContainerFactory are autoconfigured with the same MessagingMessageConverter and ObjectMapper.

Let me know if that works for you.

[bauna]

I'll try to create a minimal example, during the weekend, and get back to you.

[bauna]

Hi @tomazfernandes,
I found that autoconfiguration not always uses the same ObjectMapper instance.

For example, in AbstractMessagingMessageConverter a MappingJackson2MessageConverter is created.

private MappingJackson2MessageConverter createDefaultMappingJackson2MessageConverter() {
  MappingJackson2MessageConverter messageConverter = new MappingJackson2MessageConverter();
  messageConverter.setSerializedPayloadClass(String.class);
  messageConverter.setStrictContentTypeMatch(false);
  return messageConverter;
}

That leads to the creation of a new ObjectMapper instance without setting any module:

public class MappingJackson2MessageConverter extends AbstractMessageConverter {

	private static final MimeType[] DEFAULT_MIME_TYPES = new MimeType[] {
			new MimeType("application", "json"), new MimeType("application", "*+json")};

	private ObjectMapper objectMapper;

	@Nullable
	private Boolean prettyPrint;


	/**
	 * Construct a {@code MappingJackson2MessageConverter} with a default {@link ObjectMapper},
	 * supporting the {@code application/json} MIME type with {@code UTF-8} character set.
	 */
	public MappingJackson2MessageConverter() {
		this(DEFAULT_MIME_TYPES);
	}

	/**
	 * Construct a {@code MappingJackson2MessageConverter} with a default {@link ObjectMapper},
	 * supporting one or more custom MIME types.
	 * @param supportedMimeTypes the supported MIME types
	 * @since 4.1.5
	 */
	@SuppressWarnings("deprecation")  // on Jackson 2.13: configure(MapperFeature, boolean)
	public MappingJackson2MessageConverter(MimeType... supportedMimeTypes) {
		super(supportedMimeTypes);
		this.objectMapper = new ObjectMapper();
		this.objectMapper.configure(MapperFeature.DEFAULT_VIEW_INCLUSION, false);
		this.objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
	}

And the exception from my first message shows that is thrown from MappingJackson2MessageConverter.

[tomazfernandes]

We do create an ObjectMapper, but in

spring-cloud-aws/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/support/converter/AbstractMessagingMessageConverter.java

Lines 94 to 101 in 02e997c

	public void setObjectMapper(ObjectMapper objectMapper) {
	Assert.notNull(objectMapper, "messageConverter cannot be null");
	MappingJackson2MessageConverter converter = getMappingJackson2MessageConverter().orElseThrow(
	() -> new IllegalStateException("%s can only be set in %s instances, or %s containing one.".formatted(
	ObjectMapper.class.getSimpleName(), MappingJackson2MessageConverter.class.getSimpleName(),
	CompositeMessageConverter.class.getSimpleName())));
	converter.setObjectMapper(objectMapper);
	}

we explicitly override it.

In a typical Spring Boot application an ObjectMapper is provided by the framework, so this ObjectMapper we create is replaced in autoconfiguration.

In tests though, if you're not running it as a SpringBootTest with the full Spring Context, it won't trigger autoconfiguration and will keep this default OM.

I hope this helps - feel free to provide the sample or more context on your configuration.