SqsListener не работает в Sprint Boot 3.3.0JAVA

Программисты JAVA общаются здесь
Ответить Пред. темаСлед. тема
Anonymous
 SqsListener не работает в Sprint Boot 3.3.0

Сообщение Anonymous »

Я пытаюсь обновить одну из своих служб до Spring Boot 3.x с Spring Boot 2.7.x
Текущие версии:
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}"
}
}
Код Java:

Код: Выделить всё

@SqsListener(value = "${sqs.queue}", acknowledgementMode = ON_SUCCESS)
public void consumeMessage(String payload) {
doSomething(payload);
}
Я также пытался создать bean-компоненты SqsAsyncClient и SqsMessageListenerContainerFactory, хотя они не требуются, но я все равно не могу получить полезную нагрузку.

Код: Выделить всё

@Bean
public SqsAsyncClient sqsAsyncClient() {
return SqsAsyncClient.builder().region(Region.AP_SOUTH_1).build();
}

@Bean
public SqsMessageListenerContainerFactory defaultSqsListenerContainerFactory() {
return SqsMessageListenerContainerFactory
.builder()
.sqsAsyncClient(sqsAsyncClient())
.build();
}
Я также пытался понизить версию Spring Boot до 3.2.5, но проблема осталась та же.

Что-то мне здесь не хватает?
Заранее спасибо .

Подробнее здесь: https://stackoverflow.com/questions/785 ... boot-3-3-0
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «JAVA»