весеннее облако AWS SQS Listener Issue

Question

Я готовлю демо-программу, которая прослушивает Amazon SQS.Below - это мой код.

XML конфигурации

<aws-messaging:annotation-driven-queue-listener amazon-sqs="sqsClient" max-number-of-messages="10" wait-time-out="20" visibility-timeout="100" /> 

UserServiceListenr.java

@Configuration 
@EnableSqs 
@Component 
public class UserServiceListenr { 
    @SqsListener(value = "CMR", deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS) 
    public void myQueueListener(Message message) throws Exception{ 
     try { 
      System.out.println("Message Listen start"); 
      System.out.println("Message part "+message); 
     }catch(Exception e){ 
      System.out.println(" message Exception " + e); 
     } 
    } 
} 

Я поставил 2 сообщения на SQS queue.when Я стараюсь получать сообщения, используя эту демонстрационную программу сообщений, показанных столбец Messages_in_flight в моем AWS console.but не доходит до моего метода sqsListener и через несколько минут сообщения, отображаемые в столбце Messages_available в консоли AWS.

Ниже приведено Исключение, которое я получил при запуске программы.

QueueMessageHandler:294 - 1 message handler methods found on class com.sophos.cmr.demo.UserServiceListenr: {public void com.sophos.cmr.demo.UserServiceListenr.myQueueListener(java.lang.String) throws java.lang.Exception=org.springframework.cloud.aws.messaging.listener.QueueMessageHandler$MappingInformation@5f0e9815} 

так что происходит, если какая-либо подсказка?

Answer 1

Когда вы видите, что сообщение переместится в столбец Messages_in_flight - это означает, что сообщение было воспринято потребителем, но подтверждение об успешном обращении для этого конкретного сообщения все равно не принималось.

Так причина может быть следующее: появляется 1) Ошибка/Исключение во время обработки сообщений от SQS 2) Spring немогут найти подходящий ArgumentResolver преобразовать сообщение дохода от SQS к вашему компоненту. Я вижу, что вы используете свой пользовательский компонент - «Сообщение»

Вы можете посмотреть documentation, раздел 5.2.5