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);
}
"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? –
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