我在本地电脑中设置了 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);
}
}