import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.client.WebClient;
-import org.testcontainers.junit.jupiter.Testcontainers;
import pl.rzrz.assertj.reactor.Assertions;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.util.concurrent.CompletableFuture;
-@Testcontainers
@Slf4j
public abstract class AbstractHandoverIT
{
import reactor.core.publisher.Mono;
import reactor.util.retry.Retry;
-import java.net.InetSocketAddress;
-import java.net.SocketAddress;
import java.time.Duration;
import java.time.Instant;
import java.util.Arrays;
-import static de.juplo.kafka.chat.backend.implementation.haproxy.HaproxyDataPlaneApiShardingPublisherStrategy.*;
+import static de.juplo.kafka.chat.backend.implementation.haproxy.HaproxyDataPlaneApiShardingPublisherStrategy.MAP_PARAM;
@Slf4j
final Network network = Network.newNetwork();
final GenericContainer haproxy, backend1, backend2, backend3;
- final SocketAddress haproxyAddress;
AbstractHandoverITContainers()
backend1 = createBackendContainer("1");
backend2 = createBackendContainer("2");
backend3 = createBackendContainer("3");
-
- this.haproxyAddress = new InetSocketAddress("localhost", haproxy.getMappedPort(8401));
}