Отключить прослушиватель SQS при запуске тестового примера ⇐ JAVA

[Anonymous]

Spring Boot 2.7.5

JUnit 4.13.2
У меня есть прослушиватель SQS в приложении:

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

@Component
@EnableSqs
@Slf4j
public class SdkUploadListener {

private final S3Service s3Service;

@Autowired
public SdkUploadListener(final S3Service s3Service) {
this.s3Service = s3Service;
}

@SqsListener(value = "${amazon.sqs.sdk-upload-queue-url}", deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)
public void processMessage(final S3EventNotification message) throws JsonProcessingException {
...
}
}

Есть простой тестовый пример (просто хочу протестировать запуск Airflow Dag):

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

@SpringBootTest
@Slf4j
class AirflowClientTest {

@Autowired
private AirflowClient airflowClient;

@Test
public void testDagRun() {
final String dagName = "test-dag";
final OffsetDateTime logicalDate = OffsetDateTime.parse("2022-08-01T00:00:00.000Z");
final AirflowRunDugRequest request = new AirflowRunDugRequest(logicalDate, Map.of());
airflowClient.triggerIngestionDag(dagName, request).subscribe(res -> log.info("Response received: {}", res));
}
}

Проблема в том, что прослушиватель SQS начинает прослушивать очередь при запуске тестового набора.

Можно ли отключить прослушиватель SQS для тестов?

Значит, для этого мне нужно использовать макет?

Подробнее здесь: https://stackoverflow.com/questions/744 ... t-case-run