geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbr...@apache.org
Subject [48/51] [partial] incubator-geode git commit: Added Spotless plugin to enforce formatting standards. Added Google Java Style guide formatter templates, removed existing formatter templates.
Date Fri, 21 Oct 2016 20:31:27 GMT
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java
index f6378be..20cfeca 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter;
 
@@ -52,8 +50,8 @@ import java.util.Map;
 import java.util.UUID;
 
 /**
- * This class implements the session management using a Gemfire distributedCache
- * as a persistent store for the session objects
+ * This class implements the session management using a Gemfire distributedCache as a persistent
+ * store for the session objects
  */
 public class GemfireSessionManager implements SessionManager {
 
@@ -89,16 +87,15 @@ public class GemfireSessionManager implements SessionManager {
   private boolean isStopping = false;
 
   /**
-   * Boolean indicating whether this manager is defined in the same context (war
-   * / classloader) as the filter.
+   * Boolean indicating whether this manager is defined in the same context (war / classloader) as
+   * the filter.
    */
   private boolean isolated = false;
 
   /**
    * Map of wrapping GemFire session id to native session id
    */
-  private Map<String, String> nativeSessionMap =
-      new HashMap<String, String>();
+  private Map<String, String> nativeSessionMap = new HashMap<String, String>();
 
   /**
    * MBean for statistics
@@ -106,9 +103,8 @@ public class GemfireSessionManager implements SessionManager {
   private SessionStatistics mbean;
 
   /**
-   * This CL is used to compare against the class loader of attributes getting
-   * pulled out of the cache. This variable should be set to the CL of the
-   * filter running everything.
+   * This CL is used to compare against the class loader of attributes getting pulled out of the
+   * cache. This variable should be set to the CL of the filter running everything.
    */
   private ClassLoader referenceClassLoader;
 
@@ -123,21 +119,22 @@ public class GemfireSessionManager implements SessionManager {
    * Set up properties with default values
    */
   private TypeAwareMap<CacheProperty, Object> properties =
-      new TypeAwareMap<CacheProperty, Object>(CacheProperty.class) {{
-        put(CacheProperty.REGION_NAME, RegionHelper.NAME + "_sessions");
-        put(CacheProperty.ENABLE_GATEWAY_DELTA_REPLICATION, Boolean.FALSE);
-        put(CacheProperty.ENABLE_GATEWAY_REPLICATION, Boolean.FALSE);
-        put(CacheProperty.ENABLE_DEBUG_LISTENER, Boolean.FALSE);
-        put(CacheProperty.STATISTICS_NAME, "gemfire_statistics");
-        put(CacheProperty.SESSION_DELTA_POLICY, "delta_queued");
-        put(CacheProperty.REPLICATION_TRIGGER, "set");
-        /**
-         * For REGION_ATTRIBUTES_ID and ENABLE_LOCAL_CACHE the default
-         * is different for ClientServerCache and PeerToPeerCache
-         * so those values are set in the relevant constructors when
-         * these properties are passed in to them.
-         */
-      }};
+      new TypeAwareMap<CacheProperty, Object>(CacheProperty.class) {
+        {
+          put(CacheProperty.REGION_NAME, RegionHelper.NAME + "_sessions");
+          put(CacheProperty.ENABLE_GATEWAY_DELTA_REPLICATION, Boolean.FALSE);
+          put(CacheProperty.ENABLE_GATEWAY_REPLICATION, Boolean.FALSE);
+          put(CacheProperty.ENABLE_DEBUG_LISTENER, Boolean.FALSE);
+          put(CacheProperty.STATISTICS_NAME, "gemfire_statistics");
+          put(CacheProperty.SESSION_DELTA_POLICY, "delta_queued");
+          put(CacheProperty.REPLICATION_TRIGGER, "set");
+          /**
+           * For REGION_ATTRIBUTES_ID and ENABLE_LOCAL_CACHE the default is different for
+           * ClientServerCache and PeerToPeerCache so those values are set in the relevant
+           * constructors when these properties are passed in to them.
+           */
+        }
+      };
 
   public GemfireSessionManager() {
     LOG = LoggerFactory.getLogger(GemfireSessionManager.class.getName());
@@ -161,8 +158,7 @@ public class GemfireSessionManager implements SessionManager {
       isolated = true;
     }
 
-    String sessionCookieName = config.getInitParameter(
-        INIT_PARAM_SESSION_COOKIE_NAME);
+    String sessionCookieName = config.getInitParameter(INIT_PARAM_SESSION_COOKIE_NAME);
     if (sessionCookieName != null && !sessionCookieName.isEmpty()) {
       this.sessionCookieName = sessionCookieName;
       LOG.info("Session cookie name set to: {}", this.sessionCookieName);
@@ -173,8 +169,7 @@ public class GemfireSessionManager implements SessionManager {
       jvmId = DEFAULT_JVM_ID;
     }
 
-    LOG.info("Started GemfireSessionManager (isolated={}, jvmId={})",
-        isolated, jvmId);
+    LOG.info("Started GemfireSessionManager (isolated={}, jvmId={})", isolated, jvmId);
   }
 
   /**
@@ -199,14 +194,12 @@ public class GemfireSessionManager implements SessionManager {
    */
   @Override
   public HttpSession getSession(String id) {
-    GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(
-        id);
+    GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(id);
 
     if (session != null) {
       if (session.justSerialized()) {
         session.setManager(this);
-        LOG.debug("Recovered serialized session {} (jvmId={})", id,
-            session.getJvmOwnerId());
+        LOG.debug("Recovered serialized session {} (jvmId={})", id, session.getJvmOwnerId());
       }
       LOG.debug("Retrieved session id {}", id);
     } else {
@@ -221,28 +214,23 @@ public class GemfireSessionManager implements SessionManager {
   @Override
   public HttpSession wrapSession(HttpSession nativeSession) {
     String id = generateId();
-    GemfireHttpSession session =
-        new GemfireHttpSession(id, nativeSession);
+    GemfireHttpSession session = new GemfireHttpSession(id, nativeSession);
 
     /**
      * Set up the attribute container depending on how things are configured
      */
     AbstractSessionAttributes attributes;
-    if ("delta_queued".equals(
-        properties.get(CacheProperty.SESSION_DELTA_POLICY))) {
+    if ("delta_queued".equals(properties.get(CacheProperty.SESSION_DELTA_POLICY))) {
       attributes = new DeltaQueuedSessionAttributes();
-      ((DeltaQueuedSessionAttributes) attributes).setReplicationTrigger(
-          (String) properties.get(CacheProperty.REPLICATION_TRIGGER));
-    } else if ("delta_immediate".equals(
-        properties.get(CacheProperty.SESSION_DELTA_POLICY))) {
+      ((DeltaQueuedSessionAttributes) attributes)
+          .setReplicationTrigger((String) properties.get(CacheProperty.REPLICATION_TRIGGER));
+    } else if ("delta_immediate".equals(properties.get(CacheProperty.SESSION_DELTA_POLICY))) {
       attributes = new DeltaSessionAttributes();
-    } else if ("immediate".equals(
-        properties.get(CacheProperty.SESSION_DELTA_POLICY))) {
+    } else if ("immediate".equals(properties.get(CacheProperty.SESSION_DELTA_POLICY))) {
       attributes = new ImmediateSessionAttributes();
     } else {
       attributes = new DeltaSessionAttributes();
-      LOG.warn(
-          "No session delta policy specified - using default of 'delta_immediate'");
+      LOG.warn("No session delta policy specified - using default of 'delta_immediate'");
     }
 
     attributes.setSession(session);
@@ -279,8 +267,7 @@ public class GemfireSessionManager implements SessionManager {
   public void destroySession(String id) {
     if (!isStopping) {
       try {
-        GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(
-            id);
+        GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(id);
         if (session != null && session.getJvmOwnerId().equals(jvmId)) {
           LOG.debug("Destroying session {}", id);
           sessionCache.getOperatingRegion().destroy(id);
@@ -299,8 +286,7 @@ public class GemfireSessionManager implements SessionManager {
           // Ignored
         }
       } else {
-        GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(
-            id);
+        GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(id);
         if (session != null) {
           session.setNativeSession(null);
         }
@@ -338,13 +324,12 @@ public class GemfireSessionManager implements SessionManager {
   }
 
   /**
-   * This method is called when a native session gets destroyed. It will check
-   * if the GemFire session is actually still valid/not expired and will then
-   * attach a new, native session.
+   * This method is called when a native session gets destroyed. It will check if the GemFire
+   * session is actually still valid/not expired and will then attach a new, native session.
    *
    * @param nativeId the id of the native session
-   * @return the id of the newly attached native session or null if the GemFire
-   * session was already invalid
+   * @return the id of the newly attached native session or null if the GemFire session was already
+   *         invalid
    */
   public String refreshSession(String nativeId) {
     String gemfireId = getGemfireSessionIdFromNativeId(nativeId);
@@ -352,8 +337,8 @@ public class GemfireSessionManager implements SessionManager {
       return null;
     }
 
-    GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(
-        gemfireId);
+    GemfireHttpSession session =
+        (GemfireHttpSession) sessionCache.getOperatingRegion().get(gemfireId);
     if (session.isValid()) {
 
     }
@@ -399,27 +384,24 @@ public class GemfireSessionManager implements SessionManager {
     } else if (CACHE_TYPE_PEER_TO_PEER.equals(cacheType)) {
       distributedCache = PeerToPeerCache.getInstance();
     } else {
-      LOG.error("No 'cache-type' initialization param set. "
-          + "Cache will not be started");
+      LOG.error("No 'cache-type' initialization param set. " + "Cache will not be started");
       return;
     }
 
     if (!distributedCache.isStarted()) {
       /**
-       * Process all the init params and see if any apply to the
-       * distributed system.
+       * Process all the init params and see if any apply to the distributed system.
        */
-      for (Enumeration<String> e = config.getInitParameterNames(); e.hasMoreElements(); ) {
+      for (Enumeration<String> e = config.getInitParameterNames(); e.hasMoreElements();) {
         String param = e.nextElement();
         if (!param.startsWith(GEMFIRE_PROPERTY)) {
           continue;
         }
 
         String gemfireProperty = param.substring(GEMFIRE_PROPERTY.length());
-        LOG.info("Setting gemfire property: {} = {}",
-            gemfireProperty, config.getInitParameter(param));
-        distributedCache.setProperty(gemfireProperty,
+        LOG.info("Setting gemfire property: {} = {}", gemfireProperty,
             config.getInitParameter(param));
+        distributedCache.setProperty(gemfireProperty, config.getInitParameter(param));
       }
 
       distributedCache.lifecycleEvent(LifecycleTypeAdapter.START);
@@ -433,17 +415,16 @@ public class GemfireSessionManager implements SessionManager {
     // Retrieve the distributedCache
     GemFireCacheImpl cache = (GemFireCacheImpl) CacheFactory.getAnyInstance();
     if (cache == null) {
-      throw new IllegalStateException("No cache exists. Please configure "
-          + "either a PeerToPeerCacheLifecycleListener or "
-          + "ClientServerCacheLifecycleListener in the "
-          + "server.xml file.");
+      throw new IllegalStateException(
+          "No cache exists. Please configure " + "either a PeerToPeerCacheLifecycleListener or "
+              + "ClientServerCacheLifecycleListener in the " + "server.xml file.");
     }
 
     /**
      * Process all the init params and see if any apply to the distributedCache
      */
     ResourceManager rm = cache.getResourceManager();
-    for (Enumeration<String> e = config.getInitParameterNames(); e.hasMoreElements(); ) {
+    for (Enumeration<String> e = config.getInitParameterNames(); e.hasMoreElements();) {
       String param = e.nextElement();
 
       // Uggh - don't like this non-generic stuff
@@ -463,15 +444,13 @@ public class GemfireSessionManager implements SessionManager {
       }
 
       String gemfireWebParam = param.substring(GEMFIRE_CACHE.length());
-      LOG.info("Setting cache parameter: {} = {}",
-          gemfireWebParam, config.getInitParameter(param));
+      LOG.info("Setting cache parameter: {} = {}", gemfireWebParam, config.getInitParameter(param));
       properties.put(CacheProperty.valueOf(gemfireWebParam.toUpperCase()),
           config.getInitParameter(param));
     }
 
     // Create the appropriate session distributedCache
-    sessionCache = cache.isClient()
-        ? new ClientServerSessionCache(cache, properties)
+    sessionCache = cache.isClient() ? new ClientServerSessionCache(cache, properties)
         : new PeerToPeerSessionCache(cache, properties);
 
     // Initialize the session distributedCache
@@ -486,15 +465,12 @@ public class GemfireSessionManager implements SessionManager {
 
     try {
       InitialContext ctx = new InitialContext();
-      MBeanServer mbs = MBeanServer.class.cast(
-          ctx.lookup("java:comp/env/jmx/runtime"));
-      ObjectName oname = new ObjectName(
-          Constants.SESSION_STATISTICS_MBEAN_NAME);
+      MBeanServer mbs = MBeanServer.class.cast(ctx.lookup("java:comp/env/jmx/runtime"));
+      ObjectName oname = new ObjectName(Constants.SESSION_STATISTICS_MBEAN_NAME);
 
       mbs.registerMBean(mbean, oname);
     } catch (Exception ex) {
-      LOG.warn("Unable to register statistics MBean. Error: {}",
-          ex.getMessage());
+      LOG.warn("Unable to register statistics MBean. Error: {}", ex.getMessage());
     }
   }
 

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java
index cfb2d49..2e4337d 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter;
 
@@ -25,51 +23,40 @@ public enum ListenerEventType {
   /**
    * HttpSessionAttributeListener
    */
-  SESSION_ATTRIBUTE_ADDED,
-  SESSION_ATTRIBUTE_REMOVED,
-  SESSION_ATTRIBUTE_REPLACED,
+  SESSION_ATTRIBUTE_ADDED, SESSION_ATTRIBUTE_REMOVED, SESSION_ATTRIBUTE_REPLACED,
 
   /**
    * HttpSessionBindingListener
    */
-  SESSION_VALUE_BOUND,
-  SESSION_VALUE_UNBOUND,
+  SESSION_VALUE_BOUND, SESSION_VALUE_UNBOUND,
 
   /**
    * HttpSessionListener
    */
-  SESSION_CREATED,
-  SESSION_DESTROYED,
+  SESSION_CREATED, SESSION_DESTROYED,
 
   /**
    * HttpSessionActivationListener
    */
-  SESSION_WILL_ACTIVATE,
-  SESSION_DID_PASSIVATE,
+  SESSION_WILL_ACTIVATE, SESSION_DID_PASSIVATE,
 
   /**
    * ServletContextListener
    */
-  SERVLET_CONTEXT_INITIALIZED,
-  SERVLET_CONTEXT_DESTROYED,
+  SERVLET_CONTEXT_INITIALIZED, SERVLET_CONTEXT_DESTROYED,
 
   /**
    * ServletContextAttributeListener
    */
-  SERVLET_CONTEXT_ATTRIBUTE_ADDED,
-  SERVLET_CONTEXT_ATTRIBUTE_REMOVED,
-  SERVLET_CONTEXT_ATTRIBUTE_REPLACED,
+  SERVLET_CONTEXT_ATTRIBUTE_ADDED, SERVLET_CONTEXT_ATTRIBUTE_REMOVED, SERVLET_CONTEXT_ATTRIBUTE_REPLACED,
 
   /**
    * ServletRequestListener
    */
-  SERVLET_REQUEST_DESTROYED,
-  SERVLET_REQUEST_INITIALIZED,
+  SERVLET_REQUEST_DESTROYED, SERVLET_REQUEST_INITIALIZED,
 
   /**
    * ServletRequestAttributeListener
    */
-  SERVLET_REQUEST_ATTRIBUTE_ADDED,
-  SERVLET_REQUEST_ATTRIBUTE_REMOVED,
-  SERVLET_REQUEST_ATTRIBUTE_REPLACED;
+  SERVLET_REQUEST_ATTRIBUTE_ADDED, SERVLET_REQUEST_ATTRIBUTE_REMOVED, SERVLET_REQUEST_ATTRIBUTE_REPLACED;
 }

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java
index c59624c..642c287 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java
@@ -1,27 +1,24 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter;
 
 import javax.servlet.http.HttpSession;
 
 /**
- * Interface to session management. This class would be responsible for creating
- * new sessions.
+ * Interface to session management. This class would be responsible for creating new sessions.
  */
 public interface SessionManager {
 
@@ -29,12 +26,10 @@ public interface SessionManager {
    * Start the manager possibly using the config passed in.
    *
    * @param config Config object specific to individual implementations.
-   * @param loader This is a hack. When the manager is started it wants to be
-   *               able to determine if the cache, which it would create, and
-   *               the filter which starts everything, are defined by the same
-   *               classloader. This is so that during shutdown, the manager can
-   *               decide whether or not to also stop the cache. This option
-   *               allows the filter's classloader to be passed in.
+   * @param loader This is a hack. When the manager is started it wants to be able to determine if
+   *        the cache, which it would create, and the filter which starts everything, are defined by
+   *        the same classloader. This is so that during shutdown, the manager can decide whether or
+   *        not to also stop the cache. This option allows the filter's classloader to be passed in.
    */
   public void start(Object config, ClassLoader loader);
 
@@ -67,9 +62,8 @@ public interface SessionManager {
   public HttpSession wrapSession(HttpSession nativeSession);
 
   /**
-   * Get the wrapped (GemFire) session from a native session id. This method
-   * would typically be used from within session/http event listeners which
-   * receive the original session id.
+   * Get the wrapped (GemFire) session from a native session id. This method would typically be used
+   * from within session/http event listeners which receive the original session id.
    *
    * @param nativeId
    * @return the wrapped GemFire session which maps the native session
@@ -87,22 +81,20 @@ public interface SessionManager {
    * Destroy the session associated with a given native session
    *
    * @param id the id of the native session
-   * @return the corresponding Gemfire session which wrapped the native session
-   * and was destroyed.
+   * @return the corresponding Gemfire session which wrapped the native session and was destroyed.
    */
   public String destroyNativeSession(String id);
 
   /**
-   * Returns the cookie name used to hold the session id. By default this is
-   * JSESSIONID.
+   * Returns the cookie name used to hold the session id. By default this is JSESSIONID.
    *
    * @return the name of the cookie which contains the session id
    */
   public String getSessionCookieName();
 
   /**
-   * Get the JVM Id - this is a unique string used internally to identify who
-   * last touched a session.
+   * Get the JVM Id - this is a unique string used internally to identify who last touched a
+   * session.
    *
    * @return the jvm id
    */

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java
index 0d36932..4d1f108 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.attributes;
 
@@ -32,11 +30,10 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * This abstract class contains the structures and methods to handle delta
- * updates to attributes.
+ * This abstract class contains the structures and methods to handle delta updates to attributes.
  */
-public abstract class AbstractDeltaSessionAttributes
-    extends AbstractSessionAttributes implements Delta {
+public abstract class AbstractDeltaSessionAttributes extends AbstractSessionAttributes
+    implements Delta {
 
   private static final Logger LOG =
       LoggerFactory.getLogger(AbstractDeltaSessionAttributes.class.getName());
@@ -70,8 +67,7 @@ public abstract class AbstractDeltaSessionAttributes
   }
 
   @Override
-  public void fromDelta(DataInput in)
-      throws IOException, InvalidDeltaException {
+  public void fromDelta(DataInput in) throws IOException, InvalidDeltaException {
     maxInactiveInterval = in.readInt();
     lastAccessedTime = in.readLong();
     Map<String, DeltaEvent> localDeltas = new HashMap<String, DeltaEvent>();
@@ -87,8 +83,7 @@ public abstract class AbstractDeltaSessionAttributes
       return;
     }
 
-    LOG.debug("Processing {} delta events for {}",
-        localDeltas.size(), session);
+    LOG.debug("Processing {} delta events for {}", localDeltas.size(), session);
     for (DeltaEvent e : localDeltas.values()) {
       if (e.isUpdate()) {
         attributes.put(e.getName(), e.getValue());

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java
index 4c4564c..6e0cbc4 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.attributes;
 
@@ -33,9 +31,9 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * Abstract implementation for attributes. Should be sub-classed to provide
- * differing implementations for synchronous or delta propagation. The backing
- * store used is defined by the session manager.
+ * Abstract implementation for attributes. Should be sub-classed to provide differing
+ * implementations for synchronous or delta propagation. The backing store used is defined by the
+ * session manager.
  */
 public abstract class AbstractSessionAttributes implements SessionAttributes {
 
@@ -77,9 +75,8 @@ public abstract class AbstractSessionAttributes implements SessionAttributes {
   }
 
   /**
-   * {@inheritDoc} The actual de-serialization of any domain objects is deferred
-   * until the point at which they are actually retrieved by the application
-   * layer.
+   * {@inheritDoc} The actual de-serialization of any domain objects is deferred until the point at
+   * which they are actually retrieved by the application layer.
    */
   @Override
   public Object getAttribute(String name) {
@@ -92,8 +89,7 @@ public abstract class AbstractSessionAttributes implements SessionAttributes {
         value = BlobHelper.deserializeBlob((byte[]) value);
         attributes.put(name, value);
       } catch (Exception iox) {
-        LOG.error("Attribute '" + name +
-            " contains a byte[] that cannot be deserialized due "
+        LOG.error("Attribute '" + name + " contains a byte[] that cannot be deserialized due "
             + "to the following exception", iox);
       }
     }
@@ -133,8 +129,8 @@ public abstract class AbstractSessionAttributes implements SessionAttributes {
   }
 
   /**
-   * {@inheritDoc} This method calls back into the session to flush the whole
-   * session including its attributes.
+   * {@inheritDoc} This method calls back into the session to flush the whole session including its
+   * attributes.
    */
   @Override
   public void flush() {
@@ -142,9 +138,8 @@ public abstract class AbstractSessionAttributes implements SessionAttributes {
   }
 
   /**
-   * Use DeltaEvents to propagate the actual attribute data - DeltaEvents turn
-   * the values into byte arrays which means that the actual domain classes are
-   * not required on the server.
+   * Use DeltaEvents to propagate the actual attribute data - DeltaEvents turn the values into byte
+   * arrays which means that the actual domain classes are not required on the server.
    */
   @Override
   public void toData(DataOutput out) throws IOException {
@@ -154,8 +149,7 @@ public abstract class AbstractSessionAttributes implements SessionAttributes {
     synchronized (attributes) {
       out.writeInt(attributes.size());
       for (Map.Entry<String, Object> entry : attributes.entrySet()) {
-        DeltaEvent delta = new DeltaEvent(true, entry.getKey(),
-            entry.getValue());
+        DeltaEvent delta = new DeltaEvent(true, entry.getKey(), entry.getValue());
         DataSerializer.writeObject(delta, out);
       }
     }
@@ -164,8 +158,7 @@ public abstract class AbstractSessionAttributes implements SessionAttributes {
   }
 
   @Override
-  public void fromData(
-      DataInput in) throws IOException, ClassNotFoundException {
+  public void fromData(DataInput in) throws IOException, ClassNotFoundException {
     maxInactiveInterval = in.readInt();
     lastAccessedTime = in.readLong();
     int size = in.readInt();

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java
index 2bffadc..68c6995 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.attributes;
 
@@ -33,8 +31,7 @@ import java.io.IOException;
  */
 public class DeltaEvent implements DataSerializable {
 
-  private static final Logger LOG =
-      LoggerFactory.getLogger(DeltaEvent.class.getName());
+  private static final Logger LOG = LoggerFactory.getLogger(DeltaEvent.class.getName());
   /**
    * The event is either an update (true) or a remove (false)
    */
@@ -49,15 +46,13 @@ public class DeltaEvent implements DataSerializable {
   /**
    * Constructor for de-serialization only
    */
-  public DeltaEvent() {
-  }
+  public DeltaEvent() {}
 
   /**
-   * Constructor which creates a 'deferred' event. This is used when the value
-   * should only be applied when the object is serialized.
+   * Constructor which creates a 'deferred' event. This is used when the value should only be
+   * applied when the object is serialized.
    *
-   * @param session   the session from which the value ultimately will be
-   *                  retrieved
+   * @param session the session from which the value ultimately will be retrieved
    * @param attribute the name of the attribute
    */
   public DeltaEvent(GemfireHttpSession session, String attribute) {
@@ -110,8 +105,7 @@ public class DeltaEvent implements DataSerializable {
   }
 
   @Override
-  public void fromData(
-      DataInput in) throws IOException, ClassNotFoundException {
+  public void fromData(DataInput in) throws IOException, ClassNotFoundException {
     update = in.readBoolean();
     name = DataSerializer.readString(in);
     value = DataSerializer.readObject(in);

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java
index faa849d..a806515 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.attributes;
 
@@ -23,9 +21,8 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * This class implements delayed attribute delta propagation. Updates to
- * attributes are only propagated once the session goes out of scope - i.e. as
- * the request is done being processed.
+ * This class implements delayed attribute delta propagation. Updates to attributes are only
+ * propagated once the session goes out of scope - i.e. as the request is done being processed.
  */
 public class DeltaQueuedSessionAttributes extends AbstractDeltaSessionAttributes {
 
@@ -35,28 +32,25 @@ public class DeltaQueuedSessionAttributes extends AbstractDeltaSessionAttributes
   private Trigger trigger = Trigger.SET;
 
   private enum Trigger {
-    SET,
-    SET_AND_GET;
+    SET, SET_AND_GET;
   }
 
   /**
    * Register ourselves for de-serialization
    */
   static {
-    Instantiator.register(
-        new Instantiator(DeltaQueuedSessionAttributes.class, 3479) {
-          @Override
-          public DataSerializable newInstance() {
-            return new DeltaQueuedSessionAttributes();
-          }
-        });
+    Instantiator.register(new Instantiator(DeltaQueuedSessionAttributes.class, 3479) {
+      @Override
+      public DataSerializable newInstance() {
+        return new DeltaQueuedSessionAttributes();
+      }
+    });
   }
 
   /**
    * Default constructor
    */
-  public DeltaQueuedSessionAttributes() {
-  }
+  public DeltaQueuedSessionAttributes() {}
 
   public void setReplicationTrigger(String trigger) {
     this.trigger = Trigger.valueOf(trigger.toUpperCase());
@@ -71,8 +65,8 @@ public class DeltaQueuedSessionAttributes extends AbstractDeltaSessionAttributes
   }
 
   /**
-   * {@inheritDoc} Put an attribute, setting the dirty flag. The changes are
-   * flushed at the end of filter processing.
+   * {@inheritDoc} Put an attribute, setting the dirty flag. The changes are flushed at the end of
+   * filter processing.
    */
   @Override
   public Object putAttribute(String attr, Object value) {
@@ -82,8 +76,8 @@ public class DeltaQueuedSessionAttributes extends AbstractDeltaSessionAttributes
   }
 
   /**
-   * {@inheritDoc} Remove an attribute, setting the dirty flag. The changes are
-   * flushed at the end of filter processing.
+   * {@inheritDoc} Remove an attribute, setting the dirty flag. The changes are flushed at the end
+   * of filter processing.
    */
   @Override
   public Object removeAttribute(String attr) {

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java
index 85723ec..010d4e3 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.attributes;
 
@@ -23,13 +21,12 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * This class implements synchronous attribute delta propagation. Updates to
- * attributes are immediately propagated.
+ * This class implements synchronous attribute delta propagation. Updates to attributes are
+ * immediately propagated.
  */
 public class DeltaSessionAttributes extends AbstractDeltaSessionAttributes {
 
-  private static final Logger LOG =
-      LoggerFactory.getLogger(DeltaSessionAttributes.class.getName());
+  private static final Logger LOG = LoggerFactory.getLogger(DeltaSessionAttributes.class.getName());
 
   /**
    * Register ourselves for de-serialization
@@ -46,12 +43,11 @@ public class DeltaSessionAttributes extends AbstractDeltaSessionAttributes {
   /**
    * Default constructor
    */
-  public DeltaSessionAttributes() {
-  }
+  public DeltaSessionAttributes() {}
 
   /**
-   * {@inheritDoc} Put an attribute, setting the dirty flag and immediately
-   * flushing the delta queue.
+   * {@inheritDoc} Put an attribute, setting the dirty flag and immediately flushing the delta
+   * queue.
    */
   @Override
   public Object putAttribute(String attr, Object value) {
@@ -62,8 +58,8 @@ public class DeltaSessionAttributes extends AbstractDeltaSessionAttributes {
   }
 
   /**
-   * {@inheritDoc} Remove an attribute, setting the dirty flag and immediately
-   * flushing the delta queue.
+   * {@inheritDoc} Remove an attribute, setting the dirty flag and immediately flushing the delta
+   * queue.
    */
   @Override
   public Object removeAttribute(String attr) {

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java
index 15dd522..084be45 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.attributes;
 
@@ -24,9 +22,9 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * This class implements immediately transmitted attributes. All attributes are
- * transmitted for every attribute update. This is bound to be a performance hit
- * in some cases but ensures much higher data availability.
+ * This class implements immediately transmitted attributes. All attributes are transmitted for
+ * every attribute update. This is bound to be a performance hit in some cases but ensures much
+ * higher data availability.
  */
 public class ImmediateSessionAttributes extends AbstractSessionAttributes {
 
@@ -37,20 +35,18 @@ public class ImmediateSessionAttributes extends AbstractSessionAttributes {
    * Register ourselves for de-serialization
    */
   static {
-    Instantiator.register(
-        new Instantiator(ImmediateSessionAttributes.class, 347) {
-          @Override
-          public DataSerializable newInstance() {
-            return new ImmediateSessionAttributes();
-          }
-        });
+    Instantiator.register(new Instantiator(ImmediateSessionAttributes.class, 347) {
+      @Override
+      public DataSerializable newInstance() {
+        return new ImmediateSessionAttributes();
+      }
+    });
   }
 
   /**
    * Default constructor
    */
-  public ImmediateSessionAttributes() {
-  }
+  public ImmediateSessionAttributes() {}
 
   @Override
   public Object putAttribute(String attr, Object value) {

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java
index e1aeb0b..374e81e 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.attributes;
 
@@ -24,9 +22,8 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * This class implements an attribute container which delays sending updates
- * until the session goes out of scope. All attributes are transmitted during
- * the update.
+ * This class implements an attribute container which delays sending updates until the session goes
+ * out of scope. All attributes are transmitted during the update.
  */
 public class QueuedSessionAttributes extends AbstractSessionAttributes {
 
@@ -48,8 +45,7 @@ public class QueuedSessionAttributes extends AbstractSessionAttributes {
   /**
    * Default constructor
    */
-  public QueuedSessionAttributes() {
-  }
+  public QueuedSessionAttributes() {}
 
   @Override
   public Object putAttribute(String attr, Object value) {

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java
index a882712..4f4a2f8 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.attributes;
 
@@ -23,10 +21,9 @@ import org.apache.geode.modules.session.internal.filter.GemfireHttpSession;
 import java.util.Set;
 
 /**
- * Interface for session attribute storage. In reality, this interface is
- * responsible for anything, in the session which needs to be propagated for
- * caching - as such it also includes other 'attributes' such as
- * maxInactiveInterval and lastAccessedTime
+ * Interface for session attribute storage. In reality, this interface is responsible for anything,
+ * in the session which needs to be propagated for caching - as such it also includes other
+ * 'attributes' such as maxInactiveInterval and lastAccessedTime
  */
 public interface SessionAttributes extends DataSerializable {
 
@@ -40,7 +37,7 @@ public interface SessionAttributes extends DataSerializable {
   /**
    * Set an attribute value.
    *
-   * @param attr  the name of the attribute to set
+   * @param attr the name of the attribute to set
    * @param value the value for the attribute
    * @return the value object
    */
@@ -58,8 +55,7 @@ public interface SessionAttributes extends DataSerializable {
    * Remove the named attribute.
    *
    * @param attr the name of the attribute to remove
-   * @return the value of the attribute removed or null if the named attribute
-   * did not exist.
+   * @return the value of the attribute removed or null if the named attribute did not exist.
    */
   public Object removeAttribute(String attr);
 
@@ -111,8 +107,7 @@ public interface SessionAttributes extends DataSerializable {
   public String getJvmOwnerId();
 
   /**
-   * Set the jvmId. This is set every time the attributes are flushed to the
-   * cache.
+   * Set the jvmId. This is set every time the attributes are flushed to the cache.
    *
    * @param jvmId
    */

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java
index dbd5894..9fe9e27 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.util;
 
@@ -28,16 +26,14 @@ import java.util.logging.Logger;
  */
 public class NamedThreadFactory implements ThreadFactory {
 
-  private static final Logger LOG = Logger.getLogger(
-      NamedThreadFactory.class.getName());
+  private static final Logger LOG = Logger.getLogger(NamedThreadFactory.class.getName());
 
   private final String id;
 
   private final AtomicLong serial = new AtomicLong();
 
   /**
-   * Create a new thread factory, using the specified pool ID as a basis for
-   * naming each thread.
+   * Create a new thread factory, using the specified pool ID as a basis for naming each thread.
    *
    * @param poolID pool name/ID
    */
@@ -48,8 +44,8 @@ public class NamedThreadFactory implements ThreadFactory {
   /**
    * {@inheritDoc}
    * <p/>
-   * This implementation sets the name of the thread, sets the thread to be a
-   * daemon thread, and adds an uncaught exception handler.
+   * This implementation sets the name of the thread, sets the thread to be a daemon thread, and
+   * adds an uncaught exception handler.
    */
   @Override
   public Thread newThread(Runnable r) {
@@ -59,8 +55,7 @@ public class NamedThreadFactory implements ThreadFactory {
     thr.setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
       @Override
       public void uncaughtException(Thread t, Throwable e) {
-        LOG.log(Level.WARNING,
-            "Uncaught Exception in thread: " + t.getName(), e);
+        LOG.log(Level.WARNING, "Uncaught Exception in thread: " + t.getName(), e);
       }
     });
     return thr;

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java
index 13af79c..31dd134 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.util;
 
@@ -22,8 +20,7 @@ import javax.servlet.http.HttpSession;
 /**
  */
 public class ThreadLocalSession {
-  private static ThreadLocal<HttpSession> threadLocal =
-      new ThreadLocal<HttpSession>();
+  private static ThreadLocal<HttpSession> threadLocal = new ThreadLocal<HttpSession>();
 
   public static HttpSession get() {
     return threadLocal.get();

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java
index 7000033..2a86a06 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.filter.util;
 
@@ -40,8 +38,7 @@ public class TypeAwareMap<K extends CacheProperty, Object> extends HashMap {
       } else if (key.getClazz() == Integer.class) {
         return (Object) super.put(key, Integer.valueOf((String) value));
       } else {
-        throw new IllegalArgumentException("Value is not of type " +
-            key.getClazz().getName());
+        throw new IllegalArgumentException("Value is not of type " + key.getClazz().getName());
       }
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java
index 5fba0a5..678b53e 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java
@@ -1,19 +1,17 @@
 /*
-* Licensed to the Apache Software Foundation (ASF) under one or more
-* contributor license agreements.  See the NOTICE file distributed with
-* this work for additional information regarding copyright ownership.
-* The ASF licenses this file to You under the Apache License, Version 2.0
-* (the "License"); you may not use this file except in compliance with
-* the License.  You may obtain a copy of the License at
-*
-*      http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
 
 package org.apache.geode.modules.session.internal.jmx;
 

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java
index c219e3a..1821f62 100644
--- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java
+++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java
@@ -1,18 +1,16 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
  *
- *      http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
  */
 
 package org.apache.geode.modules.session.internal.jmx;


Mime
View raw message