private void addCorrelationIDToQueueReservedAttributes ( Map < String , MessageAttributeValue > messageAttributes , SQSMessage message ) throws JMSException { String correlationID = message . getJMSCorrelationID ( ) ; if ( correlationID != null ) { addStringAttribute ( messageAttributes , SQSMessage . JMS_SQS_CORRELATION_ID , correlationID ) ; } }
Adds the correlation ID attribute during send as part of the send message request if necessary