]> juplo.de Git - demos/kafka/chat/commitdiff
test: refactor: Cleand up - removed unused imports/variables/annotations
authorKai Moritz <kai@juplo.de>
Mon, 25 Mar 2024 21:54:08 +0000 (22:54 +0100)
committerKai Moritz <kai@juplo.de>
Mon, 25 Mar 2024 22:22:24 +0000 (23:22 +0100)
src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverITContainers.java

index d44607544e82fa0acac420f42aed25c6352ea2e7..e92155d6a2213c8bbd89f473679edf76994b4cfe 100644 (file)
@@ -9,7 +9,6 @@ import org.junit.jupiter.api.Test;
 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;
@@ -19,7 +18,6 @@ import java.util.List;
 import java.util.concurrent.CompletableFuture;
 
 
-@Testcontainers
 @Slf4j
 public abstract class AbstractHandoverIT
 {
index f7c377e8e981fe62f0824e97ef447163929687dc..0b245a9efe9dde6c9f23232a2160e6a06661070b 100644 (file)
@@ -18,13 +18,11 @@ import org.testcontainers.utility.MountableFile;
 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
@@ -35,7 +33,6 @@ public abstract class AbstractHandoverITContainers
 
   final Network network = Network.newNetwork();
   final GenericContainer haproxy, backend1, backend2, backend3;
-  final SocketAddress haproxyAddress;
 
 
   AbstractHandoverITContainers()
@@ -46,8 +43,6 @@ public abstract class AbstractHandoverITContainers
     backend1 = createBackendContainer("1");
     backend2 = createBackendContainer("2");
     backend3 = createBackendContainer("3");
-
-    this.haproxyAddress = new InetSocketAddress("localhost", haproxy.getMappedPort(8401));
   }