From 22c1332e29caf03d3f69df15382974baf348ae4a Mon Sep 17 00:00:00 2001 From: Zhelyazko Chobantonov Date: Tue, 18 Jun 2019 18:38:56 -0400 Subject: [PATCH] format --- .../tomcat/RedissonSessionManager.java | 32 +++++++++---------- .../tomcat/RedissonSessionManager.java | 32 +++++++++---------- .../tomcat/RedissonSessionManager.java | 32 +++++++++---------- .../tomcat/RedissonSessionManager.java | 32 +++++++++---------- 4 files changed, 64 insertions(+), 64 deletions(-) diff --git a/redisson-tomcat/redisson-tomcat-6/src/main/java/org/redisson/tomcat/RedissonSessionManager.java b/redisson-tomcat/redisson-tomcat-6/src/main/java/org/redisson/tomcat/RedissonSessionManager.java index acc235946..59758b59a 100644 --- a/redisson-tomcat/redisson-tomcat-6/src/main/java/org/redisson/tomcat/RedissonSessionManager.java +++ b/redisson-tomcat/redisson-tomcat-6/src/main/java/org/redisson/tomcat/RedissonSessionManager.java @@ -279,13 +279,13 @@ public class RedissonSessionManager extends ManagerBase implements Lifecycle { Pipeline pipeline = getEngine().getPipeline(); synchronized (pipeline) { contextInUse.add(((Context) getContainer()).getName()); - if (updateMode == UpdateMode.AFTER_REQUEST) { - if (updateValve == null) { - updateValve = new UpdateValve(); - pipeline.addValve(updateValve); - } - } - } + if (updateMode == UpdateMode.AFTER_REQUEST) { + if (updateValve == null) { + updateValve = new UpdateValve(); + pipeline.addValve(updateValve); + } + } + } if (readMode == ReadMode.MEMORY || broadcastSessionEvents) { RTopic updatesTopic = getTopic(); @@ -381,18 +381,18 @@ public class RedissonSessionManager extends ManagerBase implements Lifecycle { Pipeline pipeline = getEngine().getPipeline(); synchronized (pipeline) { contextInUse.remove(((Context) getContainer()).getName()); - //remove valves when all of the RedissonSessionManagers (web apps) are not in use anymore - if (contextInUse.size() == 0) { - if (updateValve != null) { - pipeline.removeValve(updateValve); - updateValve = null; - } - } + //remove valves when all of the RedissonSessionManagers (web apps) are not in use anymore + if (contextInUse.size() == 0) { + if (updateValve != null) { + pipeline.removeValve(updateValve); + updateValve = null; + } + } } if (messageListener != null) { - RTopic updatesTopic = getTopic(); - updatesTopic.removeListener(messageListener); + RTopic updatesTopic = getTopic(); + updatesTopic.removeListener(messageListener); } codecToUse = null; diff --git a/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java b/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java index 5526f46a5..c9df9ab0b 100644 --- a/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java +++ b/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java @@ -259,13 +259,13 @@ public class RedissonSessionManager extends ManagerBase { Pipeline pipeline = getEngine().getPipeline(); synchronized (pipeline) { contextInUse.add(((Context) getContainer()).getName()); - if (updateMode == UpdateMode.AFTER_REQUEST) { - if (updateValve == null) { - updateValve = new UpdateValve(); - pipeline.addValve(updateValve); - } - } - } + if (updateMode == UpdateMode.AFTER_REQUEST) { + if (updateValve == null) { + updateValve = new UpdateValve(); + pipeline.addValve(updateValve); + } + } + } if (readMode == ReadMode.MEMORY || broadcastSessionEvents) { RTopic updatesTopic = getTopic(); @@ -366,18 +366,18 @@ public class RedissonSessionManager extends ManagerBase { Pipeline pipeline = getEngine().getPipeline(); synchronized (pipeline) { contextInUse.remove(((Context) getContainer()).getName()); - //remove valves when all of the RedissonSessionManagers (web apps) are not in use anymore - if (contextInUse.size() == 0) { - if (updateValve != null) { - pipeline.removeValve(updateValve); - updateValve = null; - } - } + //remove valves when all of the RedissonSessionManagers (web apps) are not in use anymore + if (contextInUse.size() == 0) { + if (updateValve != null) { + pipeline.removeValve(updateValve); + updateValve = null; + } + } } if (messageListener != null) { - RTopic updatesTopic = getTopic(); - updatesTopic.removeListener(messageListener); + RTopic updatesTopic = getTopic(); + updatesTopic.removeListener(messageListener); } codecToUse = null; diff --git a/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java b/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java index 30b35fcea..58ca28439 100644 --- a/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java +++ b/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java @@ -257,13 +257,13 @@ public class RedissonSessionManager extends ManagerBase { Pipeline pipeline = getEngine().getPipeline(); synchronized (pipeline) { contextInUse.add(getContext().getName()); - if (updateMode == UpdateMode.AFTER_REQUEST) { - if (updateValve == null) { - updateValve = new UpdateValve(); - pipeline.addValve(updateValve); - } - } - } + if (updateMode == UpdateMode.AFTER_REQUEST) { + if (updateValve == null) { + updateValve = new UpdateValve(); + pipeline.addValve(updateValve); + } + } + } if (readMode == ReadMode.MEMORY || broadcastSessionEvents) { RTopic updatesTopic = getTopic(); @@ -364,18 +364,18 @@ public class RedissonSessionManager extends ManagerBase { Pipeline pipeline = getEngine().getPipeline(); synchronized (pipeline) { contextInUse.remove(getContext().getName()); - //remove valves when all of the RedissonSessionManagers (web apps) are not in use anymore - if (contextInUse.size() == 0) { - if (updateValve != null) { - pipeline.removeValve(updateValve); - updateValve = null; - } - } + //remove valves when all of the RedissonSessionManagers (web apps) are not in use anymore + if (contextInUse.size() == 0) { + if (updateValve != null) { + pipeline.removeValve(updateValve); + updateValve = null; + } + } } if (messageListener != null) { - RTopic updatesTopic = getTopic(); - updatesTopic.removeListener(messageListener); + RTopic updatesTopic = getTopic(); + updatesTopic.removeListener(messageListener); } codecToUse = null; diff --git a/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java index 30b35fcea..58ca28439 100644 --- a/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java +++ b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java @@ -257,13 +257,13 @@ public class RedissonSessionManager extends ManagerBase { Pipeline pipeline = getEngine().getPipeline(); synchronized (pipeline) { contextInUse.add(getContext().getName()); - if (updateMode == UpdateMode.AFTER_REQUEST) { - if (updateValve == null) { - updateValve = new UpdateValve(); - pipeline.addValve(updateValve); - } - } - } + if (updateMode == UpdateMode.AFTER_REQUEST) { + if (updateValve == null) { + updateValve = new UpdateValve(); + pipeline.addValve(updateValve); + } + } + } if (readMode == ReadMode.MEMORY || broadcastSessionEvents) { RTopic updatesTopic = getTopic(); @@ -364,18 +364,18 @@ public class RedissonSessionManager extends ManagerBase { Pipeline pipeline = getEngine().getPipeline(); synchronized (pipeline) { contextInUse.remove(getContext().getName()); - //remove valves when all of the RedissonSessionManagers (web apps) are not in use anymore - if (contextInUse.size() == 0) { - if (updateValve != null) { - pipeline.removeValve(updateValve); - updateValve = null; - } - } + //remove valves when all of the RedissonSessionManagers (web apps) are not in use anymore + if (contextInUse.size() == 0) { + if (updateValve != null) { + pipeline.removeValve(updateValve); + updateValve = null; + } + } } if (messageListener != null) { - RTopic updatesTopic = getTopic(); - updatesTopic.removeListener(messageListener); + RTopic updatesTopic = getTopic(); + updatesTopic.removeListener(messageListener); } codecToUse = null;