Текущие версии:
Spring Boot: 3.3.0
Java: 21
Spring AWS Cloud: 3.1.1
К сожалению, @SqsListener не работает, и я не получаю никаких сообщений от любая из очередей.
Файл build.gradle выглядит так
Код: Выделить всё
plugins {
id 'java'
id 'org.springframework.boot' version '3.3.0'
id 'io.spring.dependency-management' version '1.1.5'
}
repositories {
mavenCentral()
}
ext {
set('springCloudVersion', "2023.0.1")
set('springCloudAwsVersion','3.1.1')
}
dependencies {
implementation 'org.springframework.boot:spring-boot-starter-web'
implementation 'io.awspring.cloud:spring-cloud-aws-starter'
implementation 'io.awspring.cloud:spring-cloud-aws-starter-sqs'
}
dependencyManagement {
imports {
mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
mavenBom "io.awspring.cloud:spring-cloud-aws-dependencies:${springCloudAwsVersion}"
}
}
Код: Выделить всё
@SqsListener(value = "${sqs.queue}", acknowledgementMode = ON_SUCCESS)
public void consumeMessage(String payload) {
doSomething(payload);
}
Код: Выделить всё
@Bean
public SqsAsyncClient sqsAsyncClient() {
return SqsAsyncClient.builder().region(Region.AP_SOUTH_1).build();
}
@Bean
public SqsMessageListenerContainerFactory defaultSqsListenerContainerFactory() {
return SqsMessageListenerContainerFactory
.builder()
.sqsAsyncClient(sqsAsyncClient())
.build();
}
Что-то мне здесь не хватает?
Заранее спасибо .
Подробнее здесь: https://stackoverflow.com/questions/785 ... boot-3-3-0