X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryStreamProcessor.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryStreamProcessor.java;h=c4ae4ae0a0ecdd3cee579096b16b4006060968c3;hb=2b22a006cc57203406c8589687a6c729ebdbf40c;hp=3e205f67beb2d1f331b9a9bde68f7118fd3b88ba;hpb=213321a01c3b53f86eb2dd97c3f6241e9cad9045;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..c4ae4ae 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, String> 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