Skip to content

Commit e5b61fe

Browse files
Update RabbitMQContainerFactory.java
1 parent 5a6db1c commit e5b61fe

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

conduit/src/test/java/io/rtr/conduit/integration/RabbitMQContainerFactory.java

+3-2
Original file line numberDiff line numberDiff line change
@@ -4,20 +4,21 @@
44
import org.slf4j.LoggerFactory;
55
import org.testcontainers.containers.RabbitMQContainer;
66
import org.testcontainers.containers.output.Slf4jLogConsumer;
7+
import org.testcontainers.utility.DockerImageName;
78

89
public final class RabbitMQContainerFactory {
910
private static final Logger LOGGER = LoggerFactory.getLogger(RabbitMQContainerFactory.class);
1011

1112
private RabbitMQContainerFactory() {}
1213

1314
public static RabbitMQContainer createBrokerWithSingleExchangeAndQueue() {
14-
return createBrokerWithSingleExchangeAndQueue("rabbitmq:3-management");
15+
return createBrokerWithSingleExchangeAndQueue(DockerImageName.parse("rabbitmq:3-management"));
1516
}
1617

1718
/**
1819
* @param dockerImageName The name of the RabbitMQ Docker image; e.g., {@code rabbitmq:3-management}.
1920
*/
20-
public static RabbitMQContainer createBrokerWithSingleExchangeAndQueue(final String dockerImageName) {
21+
public static RabbitMQContainer createBrokerWithSingleExchangeAndQueue(final DockerImageName dockerImageName) {
2122
return new RabbitMQContainer(dockerImageName)
2223
.withReuse(true)
2324
.withLogConsumer(new Slf4jLogConsumer(LOGGER))

0 commit comments

Comments
 (0)