Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Upgrade dependencies; prepare for release

Browse Source 
* Adapt `RabbitTestContainer` to the deprecations in the Testcontainers
This commit is contained in:
Artem Bilan
2023-10-17 12:21:22 -04:00
parent bdefd8a6ec
commit bb908d8077
2 changed files with 29 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-integration-amqp/src/test/java/org/springframework/integration/amqp/support/RabbitTestContainer.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2022 the original author or authors.
* Copyright 2022-2023 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -16,6 +16,7 @@
package org.springframework.integration.amqp.support;
import java.io.IOException;
import java.time.Duration;
import org.junit.jupiter.api.BeforeAll;
@@ -27,6 +28,7 @@ import org.testcontainers.junit.jupiter.Testcontainers;
*
* @author Chris Bono
* @author Gary Russell
* @author Artem Bilan
*/
@Testcontainers(disabledWithoutDocker = true)
public interface RabbitTestContainer {
@@ -34,12 +36,12 @@ public interface RabbitTestContainer {
RabbitMQContainer RABBITMQ = new RabbitMQContainer("rabbitmq:management")
.withExposedPorts(5672, 15672, 5552)
.withEnv("RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS", "-rabbitmq_stream advertised_host localhost")
.withPluginsEnabled("rabbitmq_stream")
.withStartupTimeout(Duration.ofMinutes(2));
@BeforeAll
static void startContainer() {
static void startContainer() throws IOException, InterruptedException {
RABBITMQ.start();
RABBITMQ.execInContainer("rabbitmq-plugins", "enable", "rabbitmq_stream");
}
static int amqpPort() {