@ Override public void notifyMessageReceived ( SQSMessage message ) throws JMSException { SQSMessageIdentifier messageIdentifier = SQSMessageIdentifier . fromSQSMessage ( message ) ; unAckMessages . put ( message . getReceiptHandle ( ) , messageIdentifier ) ; }
Updates the internal data structure for the consumed but not acknowledged message .