in src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedClient.java [993:1009]
private Map<String, MessageAttributeValue> updateMessageAttributePayloadSize(
Map<String, MessageAttributeValue> messageAttributes, Long messageContentSize) {
Map<String, MessageAttributeValue> updatedMessageAttributes = new HashMap<>(messageAttributes);
// Add a new message attribute as a flag
MessageAttributeValue.Builder messageAttributeValueBuilder = MessageAttributeValue.builder();
messageAttributeValueBuilder.dataType("Number");
messageAttributeValueBuilder.stringValue(messageContentSize.toString());
MessageAttributeValue messageAttributeValue = messageAttributeValueBuilder.build();
if (!clientConfiguration.usesLegacyReservedAttributeName()) {
updatedMessageAttributes.put(SQSExtendedClientConstants.RESERVED_ATTRIBUTE_NAME, messageAttributeValue);
} else {
updatedMessageAttributes.put(LEGACY_RESERVED_ATTRIBUTE_NAME, messageAttributeValue);
}
return updatedMessageAttributes;
}