X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryStreamProcessor.java;h=ff7c1501c0a7cae4e2373d729bf240f18677ff47;hb=57f47fca712981116b726e437f589ac727c5d0a7;hp=3e205f67beb2d1f331b9a9bde68f7118fd3b88ba;hpb=030c0db664cea0ec3e4307065054c449dbca6be2;p=demos%2Fkafka%2Fwordcount

diff --git a/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java b/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java
index 3e205f6..ff7c150 100644
--- a/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java
+++ b/src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java
@@ -88,6 +88,11 @@ public class QueryStreamProcessor
 		return topology;
 	}
 
+	ReadOnlyKeyValueStore<String, UserRanking> getStore()
+	{
+		return streams.store(storeParameters);
+	}
+
 	public Optional<URI> getRedirect(String username)
 	{
 		KeyQueryMetadata metadata = streams.queryMetadataForKey(STORE_NAME, username, Serdes.String().serializer());
@@ -108,7 +113,7 @@ public class QueryStreamProcessor
 	{
 		return
 				Optional
-						.ofNullable(streams.store(storeParameters).get(username))
+						.ofNullable(getStore().get(username))
 						.map(json ->
 						{
 							try