@SqsListener不消费队列中的消息

Question

我正在使用我的spring引导代码连接到AWS SQS服务。现在我正在使用Localstack，但这个问题仍然存在于AWS控制台中。我可以将消息发送到队列，但我的sqsListener没有读取和记录消息。

@PostMapping("/send_message")
    public EmployeeModel sendMessage(@RequestBody EmployeeModel employee) {

        try {
            ObjectMapper mapper = new ObjectMapper();
            String jsonString = mapper.writeValueAsString(employee);
            queueMessagingTemplate.send(endPoint, MessageBuilder.withPayload(jsonString).build());
            logger.info("Message sent successfully  " + jsonString);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return employee;
    }

    @SqsListener(value = {"http://localhost:4566/000000000000/employeeTest"}, deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)
    public void receiveMessage(String stringJson) {

        logger.info("Message Received using SQS Listener " + stringJson);
        //System.out.println(stringJson);

    }

这些是我在gradle中使用的依赖项。

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
    implementation 'org.springframework.boot:spring-boot-starter-web'
    
    implementation platform('com.amazonaws:aws-java-sdk-bom:1.11.1000')
    implementation 'org.springframework.cloud:spring-cloud-aws-core:2.2.6.RELEASE'

    implementation 'org.springframework.cloud:spring-cloud-aws-messaging:2.2.6.RELEASE'

    
    runtimeOnly 'mysql:mysql-connector-java'
    testImplementation 'org.springframework.boot:spring-boot-starter-test'
}

我没有收到任何运行时错误或任何类型的错误。只是当我发送了一条消息时，sqs侦听器并不使用该消息。

Answer 1

您需要更新以下依赖项才能开始消费消息。

更新以下依赖项。

implementation 'org.springframework.cloud:spring-cloud-aws-messaging'

至

org.springframework.cloud:spring-cloud-starter-aws-messaging