WIP:haproxy

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 296d64fe88a474dcb825437ffd0422d0cce8b962..7835b1880fd7a0c848f083cbafbe05f2b6bf4a11 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
@@ -13,7 +13,7 @@ import java.net.URI;
 @Slf4j
 public class HaproxyShardingPublisherStrategy implements ShardingPublisherStrategy
 {
-  private final URI runtimeApiUri;
+  private final String instanceId;
   private final WebClient webClient;
 
 

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 4f646f60d078752e9d669061afc1913d74b1ad04..a575e07d45de33eefd4c48588e3e6154e5cdc679 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
@@ -285,10 +285,12 @@ public class KafkaServicesConfiguration
   @Bean
   ShardingPublisherStrategy shardingPublisherStrategy(
       ChatBackendProperties properties,
-      WebClient webClient)
+      WebClient.Builder webClientBuilder)
   {
+    String baseUrl = properties.getHaproxyRuntimeApiUri().toASCIIString();
+    WebClient webClient = webClientBuilder.baseUrl(baseUrl).build();
     return new HaproxyShardingPublisherStrategy(
-        properties.getHaproxyRuntimeApiUri(),
+        properties.getHaproxyInstanceId(),
         webClient);
   }