From: Kai Moritz <kai@juplo.de>
Date: Sun, 17 Mar 2024 21:01:08 +0000 (+0100)
Subject: refactor: Renamed `ShardingStrategy` for HAProxy Runtime API -- ALIGN
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=73f8322e6143e0e0a0fb4b820030aebceaacd3d3;p=demos%2Fkafka%2Fchat

refactor: Renamed `ShardingStrategy` for HAProxy Runtime API -- ALIGN
---

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyRuntimeApiShardingPublisherStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyRuntimeApiShardingPublisherStrategy.java
index ad71d497..51476066 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyRuntimeApiShardingPublisherStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyRuntimeApiShardingPublisherStrategy.java
@@ -12,7 +12,7 @@ import java.nio.channels.SocketChannel;
 
 @RequiredArgsConstructor
 @Slf4j
-public class HaproxyShardingPublisherStrategy implements ShardingPublisherStrategy
+public class HaproxyRuntimeApiShardingPublisherStrategy implements ShardingPublisherStrategy
 {
   private final SocketAddress haproxyAddress;
   private final String map;
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 58e11173..d9e85b40 100644
--- 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
@@ -2,7 +2,7 @@ package de.juplo.kafka.chat.backend.implementation.kafka;
 
 import de.juplo.kafka.chat.backend.ChatBackendProperties;
 import de.juplo.kafka.chat.backend.domain.ShardingPublisherStrategy;
-import de.juplo.kafka.chat.backend.implementation.haproxy.HaproxyShardingPublisherStrategy;
+import de.juplo.kafka.chat.backend.implementation.haproxy.HaproxyRuntimeApiShardingPublisherStrategy;
 import de.juplo.kafka.chat.backend.implementation.kafka.messages.AbstractMessageTo;
 import de.juplo.kafka.chat.backend.implementation.kafka.messages.data.EventChatMessageReceivedTo;
 import de.juplo.kafka.chat.backend.implementation.kafka.messages.info.EventChatRoomCreated;
@@ -299,7 +299,7 @@ public class KafkaServicesConfiguration
   {
     String[] parts = properties.getKafka().getHaproxyRuntimeApi().split(":");
     InetSocketAddress haproxyAddress = new InetSocketAddress(parts[0], Integer.valueOf(parts[1]));
-    return new HaproxyShardingPublisherStrategy(
+    return new HaproxyRuntimeApiShardingPublisherStrategy(
         haproxyAddress,
         properties.getKafka().getHaproxyMap(),
         properties.getInstanceId());