@JmsListener(id=HerdJmsDestinationResolver.SQS_DESTINATION_HERD_INCOMING,containerFactory="jmsListenerContainerFactory",destination=HerdJmsDestinationResolver.SQS_DESTINATION_HERD_INCOMING) public void processMessage(String payload,@Headers Map<Object,Object> allHeaders){
  LOGGER.info("JMS message received from the queue. jmsQueueName=\"{}\" jmsMessageHeaders=\"{}\" jmsMessagePayload={}",HerdJmsDestinationResolver.SQS_DESTINATION_HERD_INCOMING,allHeaders,payload);
  boolean messageProcessed=processS3Notification(payload);
  if (!messageProcessed) {
    messageProcessed=processEsbSystemMonitorMessage(payload);
  }
  if (!messageProcessed) {
    LOGGER.error("Failed to process message from the JMS queue. jmsQueueName=\"{}\" jmsMessagePayload={}",HerdJmsDestinationResolver.SQS_DESTINATION_HERD_INCOMING,payload);
  }
}

@ JmsListener ( id = HerdJmsDestinationResolver . SQS_DESTINATION_HERD_INCOMING , containerFactory = "jmsListenerContainerFactory" , destination = HerdJmsDestinationResolver . SQS_DESTINATION_HERD_INCOMING ) public void processMessage ( String payload , @ Headers Map < Object , Object > allHeaders ) { LOGGER . info ( "JMS message received from the queue. jmsQueueName=\"{}\" jmsMessageHeaders=\"{}\" jmsMessagePayload={}" , HerdJmsDestinationResolver . SQS_DESTINATION_HERD_INCOMING , allHeaders , payload ) ; boolean messageProcessed = processS3Notification ( payload ) ; if ( ! messageProcessed ) { messageProcessed = processEsbSystemMonitorMessage ( payload ) ; } if ( ! messageProcessed ) { LOGGER . error ( "Failed to process message from the JMS queue. jmsQueueName=\"{}\" jmsMessagePayload={}" , HerdJmsDestinationResolver . SQS_DESTINATION_HERD_INCOMING , payload ) ; } }
processes a jms message .
