0

Je peux envoyer des messages à la file d'attente SQS à partir de ma springboot, mais je ne peux pas recevoir d'annotation sqslistener. Quelqu'un peut-il m'aider?SQSlistener ne pas recevoir de messages

public void send(String message) { 


    queueMessagingTemplate.convertAndSend("test-queue", MessageBuilder.withPayload(message).build()); 
} 

@SqsListener(value = "test-queue", deletionPolicy = SqsMessageDeletionPolicy.NEVER) 
public void receive(String message) 
{ 
    System.out.println("message: " + message); 
} 

J'ai vérifié envoyer par goign à la console AWS, je peux voir mes messages dans la file d'attente, mais ils ne viennent pas recevoir méthode. config:

@Bean 
public AmazonSQSAsyncClient amazonSQSAsyncClient() 
{ 

    AmazonSQSAsyncClient amazonSQSAsyncClient= new AmazonSQSAsyncClient(amazonAWSCredentials()); 

    if (!StringUtils.isEmpty(amazonSqsEndpoint)) { 
     amazonSQSAsyncClient.setEndpoint(amazonSqsEndpoint); 

    } 

} 

@Bean 
public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory() { 
    SimpleMessageListenerContainerFactory msgListenerContainerFactory = new SimpleMessageListenerContainerFactory(); 
    msgListenerContainerFactory.setAmazonSqs(amazonSQSAsyncClient()); 
    return msgListenerContainerFactory; 
} 

@Bean 
public QueueMessagingTemplate queueMessagingTemplate(AmazonSQSAsync amazonSqs) { 
    return new QueueMessagingTemplate(amazonSQSAsyncClient()); 
} 

@Bean 
public BasicAWSCredentials amazonAWSCredentials() { 
    return new BasicAWSCredentials(amazonAWSAccessKey, amazonAWSSecretKey); 
} 
+0

"Ne fonctionne pas" n'est simplement pas assez d'information pour que quelqu'un puisse vous aider. Avez-vous activé la journalisation DEBUG? Que vois-tu? –

+0

Salut, c'est la partie étrange, il n'y a pas d'erreur, une fois que j'envoie le message il n'y a rien imprimé, le message va et se trouve dans la file d'attente et l'auditeur ne reçoit pas les messages! – Bhargav

Répondre

0

Il s'avère que j'ai eu une faute de frappe dans les noms de file d'attente dans la console SQS et mon code, mon mauvais.