WIP:haproxy

diff --git a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java
index de2dc0d9376bce19de340bcfdfd5b3a57640b872..8f151e2ca2e133e3abe02a6d3b4941b93a00db97 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java
@@ -18,7 +18,7 @@ public class ChatBackendProperties
   private ServiceType services = ServiceType.inmemory;
   private InMemoryServicesProperties inmemory = new InMemoryServicesProperties();
   private KafkaServicesProperties kafka = new KafkaServicesProperties();
-  private URI haproxyRuntimeApiUri = URI.create("haproxy:8401");
+  private String haproxyRuntimeApi = "haproxy:8401";
   private String haproxyInstanceId = "DEV";
 
 

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyShardingPublisherStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyShardingPublisherStrategy.java
index 59917091016be833ad694a1c5aec3279d6e6755e..e22d75f8f4f9256031d49a2e8b5853362bf586cb 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyShardingPublisherStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyShardingPublisherStrategy.java
@@ -3,18 +3,16 @@ package de.juplo.kafka.chat.backend.implementation.haproxy;
 import de.juplo.kafka.chat.backend.domain.ShardingPublisherStrategy;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Mono;
 
-import java.net.URI;
-
 
 @RequiredArgsConstructor
 @Slf4j
 public class HaproxyShardingPublisherStrategy implements ShardingPublisherStrategy
 {
+  private final String host;
+  private final int port;
   private final String instanceId;
-  private final WebClient webClient;
 
 
   @Override

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
index a575e07d45de33eefd4c48588e3e6154e5cdc679..c6822d67be001df6b2d1baccdbc1b31680af6ceb 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
@@ -284,14 +284,13 @@ public class KafkaServicesConfiguration
 
   @Bean
   ShardingPublisherStrategy shardingPublisherStrategy(
-      ChatBackendProperties properties,
-      WebClient.Builder webClientBuilder)
+      ChatBackendProperties properties)
   {
-    String baseUrl = properties.getHaproxyRuntimeApiUri().toASCIIString();
-    WebClient webClient = webClientBuilder.baseUrl(baseUrl).build();
+    String[] parts = properties.getHaproxyRuntimeApi().split(":");
     return new HaproxyShardingPublisherStrategy(
-        properties.getHaproxyInstanceId(),
-        webClient);
+        parts[0],
+        Integer.valueOf(parts[1]),
+        properties.getHaproxyInstanceId());
   }
 
   @Bean