Missing SNS attributes when sending a message via SnsTemplate and receiving via @SqsListener

[mt-ocado]

Type: Bug

Component: SNS, SQS

Description
Reference documentation mentions that when we receive SNS messages through the @SqsListener, the message includes all attributes of the SnsNotification. However, the attributes are not passed to message headers.

Sample
Having an SQS queue that is subscribed to SNS topic (raw message delivery is disabled), when sending to SNS via snsTemplate as following

 snsTemplate.convertAndSend(topicName, pojo, Map.of("my-attribute", "attribute-value"));

and receiving the message via @SqsListener as following

 @SqsListener("${queueName}")
 public void processGreetingsEvent(Message<?> message){
     System.out.println(message.getHeaders().get("my-attribute"))
 }

then null is printed instead of "attribute-value".

The same effect is seen when receiving as following

@SqsListener("${queue.name}")
public void processGreetingsEvent(@SnsNotificationMessage Pojo pojo, @Headers Map<String, Object> headers) {
    headers.get("my-attribute"))
}

Am I missing something? Is there a way I can access the attributes (I did not find direct information in the documentation).

[tomazfernandes]

@MatejNedic, I think this could be on either SNS or SQS side.

Now that I think of it, I remember someone else mentioning the same behavior recently.

What do you think, could it be anything on SNS? Do you remember what it was, perhaps a recent Modulith PR?

If SNS passes along the attributes to SQS, it shouldn't require any special treatment as far as I can think of.

Please let me know your thoughts, thanks!

[MatejNedic]

Will take a look in the following days

[MatejNedic]

I will have to lift whole integration up to see what is happening. Sns headers are being sent in tests. Let me check further