Updated to support latest version of rabbitmq for test containers.

This commit is contained in:
Glenn Renfro
2021-01-06 11:52:54 -05:00
parent 18cf866e8a
commit bb7567b851
6 changed files with 6 additions and 6 deletions

View File

@@ -88,7 +88,7 @@ public class TaskLauncherSinkTests {
randomPort = SocketUtils.findAvailableTcpPort();
DATASOURCE_URL = "jdbc:h2:tcp://localhost:" + randomPort
+ "/mem:dataflow;DB_CLOSE_DELAY=-1;" + "DB_CLOSE_ON_EXIT=FALSE";
GenericContainer rabbitmq = new RabbitMQContainer("rabbitmq:3.7")
GenericContainer rabbitmq = new RabbitMQContainer("rabbitmq:3.8.9")
.withExposedPorts(5672);
rabbitmq.start();
final Integer mappedPort = rabbitmq.getMappedPort(5672);

View File

@@ -51,7 +51,7 @@ public class BatchExecutionEventTests {
private static final String TASK_NAME = "jobEventTest";
static {
GenericContainer rabbitmq = new RabbitMQContainer("rabbitmq:3.7")
GenericContainer rabbitmq = new RabbitMQContainer("rabbitmq:3.8.9")
.withExposedPorts(5672);
rabbitmq.start();
final Integer mappedPort = rabbitmq.getMappedPort(5672);

View File

@@ -57,7 +57,7 @@ public class TaskEventTests {
private static final String TASK_NAME = "taskEventTest";
static {
GenericContainer rabbitmq = new RabbitMQContainer("rabbitmq:3.7")
GenericContainer rabbitmq = new RabbitMQContainer("rabbitmq:3.8.9")
.withExposedPorts(5672);
rabbitmq.start();
final Integer mappedPort = rabbitmq.getMappedPort(5672);