From 91706a8a14242475193d324a251b76d68a6d6f3f Mon Sep 17 00:00:00 2001 From: John Blum Date: Wed, 1 Nov 2017 17:20:06 -0700 Subject: [PATCH] Add @Override annotation to the findByIndexNameAndIndexValue(..) method. Iterate the o.a.g.cache.query.SearchResults using the Collection.forEach(..) method to add the queried, returned o.s.s.Sessions to a Map. --- .../data/gemfire/GemFireOperationsSessionRepository.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/spring-session-data-geode/src/main/java/org/springframework/session/data/gemfire/GemFireOperationsSessionRepository.java b/spring-session-data-geode/src/main/java/org/springframework/session/data/gemfire/GemFireOperationsSessionRepository.java index d91175a..b63ad09 100644 --- a/spring-session-data-geode/src/main/java/org/springframework/session/data/gemfire/GemFireOperationsSessionRepository.java +++ b/spring-session-data-geode/src/main/java/org/springframework/session/data/gemfire/GemFireOperationsSessionRepository.java @@ -74,15 +74,14 @@ public class GemFireOperationsSessionRepository extends AbstractGemFireOperation * @see java.util.Map * @see #prepareQuery(String) */ + @Override public Map findByIndexNameAndIndexValue(String indexName, String indexValue) { SelectResults results = getTemplate().find(prepareQuery(indexName), indexValue); Map sessions = new HashMap<>(results.size()); - for (Session session : results.asList()) { - sessions.put(session.getId(), session); - } + results.asList().forEach(session -> sessions.put(session.getId(), session)); return sessions; }