You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2016/10/26 21:23:05 UTC
[48/52] [partial] incubator-geode git commit: Added Spotless plugin
to enforce formatting standards. Added Google Java Style guide formatter
templates, removed existing formatter templates.
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;