From 6c5e42de43030ce2e5d63be537d8d5a371369a8b Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 9 Jun 2024 09:46:54 +0200
Subject: [PATCH] query: 1.0.6 - Refined naming in
`QueryApplicationConfiguration` -- streamlined the naming of attributes and
parameters
---
.../query/QueryApplicationConfiguration.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java b/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
index dfc4339..9f6769f 100644
--- a/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
@@ -20,14 +20,14 @@ public class QueryApplicationConfiguration
@Bean
public QueryStreamProcessor streamProcessor(
ServerProperties serverProperties,
- QueryApplicationProperties properties,
+ QueryApplicationProperties applicationProperties,
ObjectMapper mapper,
ConfigurableApplicationContext context) throws IOException
{
String host;
if (serverProperties.getAddress() == null)
{
- HostInfo bootstrapServer = HostInfo.buildFromEndpoint(properties.getBootstrapServer());
+ HostInfo bootstrapServer = HostInfo.buildFromEndpoint(applicationProperties.getBootstrapServer());
Socket socket = new Socket();
socket.connect(new InetSocketAddress(bootstrapServer.host(), bootstrapServer.port()));
host = socket.getLocalAddress().getHostAddress();
@@ -40,11 +40,11 @@ public class QueryApplicationConfiguration
Integer port = serverProperties.getPort() == null ? 8080 : serverProperties.getPort();
return new QueryStreamProcessor(
- properties.getApplicationId(),
+ applicationProperties.getApplicationId(),
new HostInfo(host, port),
- properties.getBootstrapServer(),
- properties.getUsersInputTopic(),
- properties.getRankingInputTopic(),
+ applicationProperties.getBootstrapServer(),
+ applicationProperties.getUsersInputTopic(),
+ applicationProperties.getRankingInputTopic(),
mapper,
context);
}
--
2.20.1