From 73f8322e6143e0e0a0fb4b820030aebceaacd3d3 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 17 Mar 2024 22:01:08 +0100 Subject: [PATCH] refactor: Renamed `ShardingStrategy` for HAProxy Runtime API -- ALIGN --- .../haproxy/HaproxyRuntimeApiShardingPublisherStrategy.java | 2 +- .../implementation/kafka/KafkaServicesConfiguration.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) 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()); -- 2.20.1