Skip to content

Commit

Permalink
Use followOutput for lra-coordinator container
Browse files Browse the repository at this point in the history
  • Loading branch information
marcosgopen committed Mar 1, 2024
1 parent f097c86 commit a2a61c6
Showing 1 changed file with 6 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4,21 +4,24 @@
import java.net.ServerSocket;

import org.jboss.arquillian.core.api.annotation.Observes;
import org.jboss.logging.Logger;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerImageName;

public class LRACoordinatorManager {

private static final int DEFAULT_PRECEDENCE = -100;
private static final Logger LOGGER = Logger.getLogger(LRACoordinatorManager.class);
private static final Logger LOGGER = LoggerFactory.getLogger(LRACoordinatorManager.class);
private final int coordinatorPort = getFreePort(50000, 60000);

private GenericContainer coordinatorContainer;

public void beforeClass(
@Observes(precedence = DEFAULT_PRECEDENCE) org.jboss.arquillian.test.spi.event.suite.BeforeSuite event) {
Slf4jLogConsumer logConsumer = new Slf4jLogConsumer(LOGGER);
if (System.getProperty("lra.coordinator.url") == null) {
LOGGER.debug("Starting LRA coordinator on port " + coordinatorPort);
coordinatorContainer = new GenericContainer<>(DockerImageName.parse("quay.io/jbosstm/lra-coordinator:latest"))
Expand All @@ -30,7 +33,7 @@ public void beforeClass(
;

coordinatorContainer.start();

coordinatorContainer.followOutput(logConsumer);
System.setProperty("lra.coordinator.url", String.format("http://localhost:%d/lra-coordinator", coordinatorPort));
}
}
Expand Down

0 comments on commit a2a61c6

Please sign in to comment.