(ignite-extensions) branch master updated: IGNITE-22311 Checkstyle fixes (#267)

[anovikov]

This is an automated email from the ASF dual-hosted git repository.

anovikov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git


The following commit(s) were added to refs/heads/master by this push:
     new 17a3883b IGNITE-22311 Checkstyle fixes (#267)
17a3883b is described below

commit 17a3883bdc8efa37b1391b316a7eb73500cbb495
Author: Nusrat Shakarov <nusrat...@gmail.com>
AuthorDate: Thu May 23 11:43:30 2024 +0200

    IGNITE-22311 Checkstyle fixes (#267)
---
 .../spring/sessions/IgniteIndexedSessionRepository.java  | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)

diff --git 
a/modules/spring-session-ext/src/main/java/org/apache/ignite/spring/sessions/IgniteIndexedSessionRepository.java
 
b/modules/spring-session-ext/src/main/java/org/apache/ignite/spring/sessions/IgniteIndexedSessionRepository.java
index c7857b1e..636aac0f 100644
--- 
a/modules/spring-session-ext/src/main/java/org/apache/ignite/spring/sessions/IgniteIndexedSessionRepository.java
+++ 
b/modules/spring-session-ext/src/main/java/org/apache/ignite/spring/sessions/IgniteIndexedSessionRepository.java
@@ -22,7 +22,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
-import jakarta.annotation.PreDestroy;
 import javax.cache.configuration.CacheEntryListenerConfiguration;
 import javax.cache.configuration.Factory;
 import javax.cache.event.CacheEntryCreatedListener;
@@ -33,6 +32,7 @@ import javax.cache.event.CacheEntryListener;
 import javax.cache.event.CacheEntryListenerException;
 import javax.cache.event.CacheEntryRemovedListener;
 import javax.cache.expiry.TouchedExpiryPolicy;
+import jakarta.annotation.PreDestroy;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.ignite.cache.query.QueryCursor;
@@ -281,10 +281,10 @@ public class IgniteIndexedSessionRepository
             return null;
         }
 
-        MapSession mapSession = saved.getDelegate();
-        mapSession.setSessionIdGenerator(this.sessionIdGenerator);
+        MapSession mapSes = saved.getDelegate();
+        mapSes.setSessionIdGenerator(this.sessionIdGenerator);
 
-        return new IgniteSession(mapSession, idxResolver, false, saveMode, 
this::flushImmediateIfNecessary);
+        return new IgniteSession(mapSes, idxResolver, false, saveMode, 
this::flushImmediateIfNecessary);
     }
 
     /** {@inheritDoc} */
@@ -410,7 +410,13 @@ public class IgniteIndexedSessionRepository
             if (oldSes == null)
                 break;
 
-            updatedSes = new IgniteSession(new 
MapSession(oldSes.getDelegate()), idxResolver, false, saveMode, 
this::flushImmediateIfNecessary);
+            updatedSes = new IgniteSession(
+                new MapSession(oldSes.getDelegate()),
+                idxResolver,
+                false,
+                saveMode,
+                this::flushImmediateIfNecessary
+            );
             copyChanges(updatedSes, ses);
 
             if (attempt > MAX_UPDATE_ATTEMPT) {