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 ad71d497c21436e8a712239df49a91f298b0a26e..51476066e98eec780eaddfdd141329b318cbb836 100644 (file)
--- 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 58e111734d40b8c20a7bd39ff710951ece8a4353..d9e85b4089255895a2a0b001012f5e36a4045a4e 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
@@ -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());