0

我能够从我的springboot发送消息到SQS队列,但无法使用sqslistener注释接收,有人可以帮忙吗?SQSlistener没有收到消息

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); 
} 

我已经验证通过goign到AWS控制台发送,我可以看到我的消息队列中,但他们不是来接受的方法。 配置:

@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

“不起作用”根本没有足够的信息给任何人来帮助你。你打开了DEBUG日志?你看到了什么? –

+0

嗨,多数民众赞成在奇怪的部分,没有错误,一旦我发送消息没有什么打印,消息去坐在队列和听众根本没有得到消息! – Bhargav

回答

0

结果我发现我在SQS控制台和我的代码,我的坏队列名称的拼写错误。