2

我在本地电脑中设置了 locastack。我能够使用命令行在队列中创建、发送和接收。

我如何尝试将SpringBoot 应用程序与 localstcak 队列连接起来。

我没有找到任何教程来指导我如何使用 spring cloud 从 localstack 队列中读取数据

我有一个看起来像这样的课程

@Component
@Profile("aws")
public class EventListener {

    private static final Logger LOGGER = LoggerFactory.getLogger(VisitsQueue.class);

    @Value("${sqs.queuename}")
    private String queueName;

    private ObjectMapper mapper = new ObjectMapper();

    @RuntimeUse
    @SqsListener("${sqs.queuename}")
    public void receiveMessage(String message, @Header(value = "SenderId", required = false) String senderId,
            @Headers Map<String, Object> allHeaders) {
        LOGGER.info("Received message with content {}", message);
    }
}
4

0 回答 0