Spring/spring-session-data-geode
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Edit Javadoc.

Browse Source 
Format source code.

Optimize imports.

Change generic type signature in GemFireSession casts to use wildcard.
This commit is contained in:
John Blum
2020-02-04 11:24:12 -08:00
parent b8c3d691b4
commit f8efffa6a7
1 changed files with 24 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
spring-session-data-geode/src/integration-test/java/org/springframework/session/data/gemfire/ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegrationTests.java
View File

@@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.session.data.gemfire; package org.springframework.session.data.gemfire;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
@@ -34,18 +33,19 @@ import java.util.Objects;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;
import java.util.function.Predicate; import java.util.function.Predicate;
import edu.umd.cs.mtc.TestFramework;
import org.junit.Before; import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.Test; import org.junit.Test;
import org.junit.runner.RunWith; import org.junit.runner.RunWith;
import org.mockito.Mockito; import org.mockito.Mockito;
import edu.umd.cs.mtc.TestFramework;
import org.apache.geode.DataSerializer; import org.apache.geode.DataSerializer;
import org.apache.geode.cache.DataPolicy; import org.apache.geode.cache.DataPolicy;
import org.apache.geode.cache.GemFireCache; import org.apache.geode.cache.GemFireCache;
import org.apache.geode.cache.Region; import org.apache.geode.cache.Region;
import org.apache.geode.cache.client.ClientCache;
import org.apache.geode.cache.client.ClientRegionShortcut; import org.apache.geode.cache.client.ClientRegionShortcut;
import org.apache.geode.cache.client.Pool; import org.apache.geode.cache.client.Pool;
import org.apache.geode.cache.client.PoolManager; import org.apache.geode.cache.client.PoolManager;
@@ -62,10 +62,25 @@ import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner; import org.springframework.test.context.junit4.SpringRunner;
/** /**
* The ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegrationTests class... * Integration Tests testing the concurrent access of a {@link Session} stored in an Apache Geode
* {@link ClientCache client} {@link ClientRegionShortcut#LOCAL} {@link Region}.
* *
* @author John Blum * @author John Blum
* @since 1.0.0 * @see java.time.Instant
* @see org.junit.Test
* @see org.mockito.Mockito
* @see org.apache.geode.DataSerializer
* @see org.apache.geode.cache.GemFireCache
* @see org.apache.geode.cache.Region
* @see org.apache.geode.cache.client.ClientCache
* @see org.apache.geode.cache.client.Pool
* @see org.apache.geode.cache.client.PoolManager
* @see org.springframework.session.Session
* @see org.springframework.session.data.gemfire.AbstractConcurrentSessionOperationsIntegrationTests
* @see org.springframework.session.data.gemfire.serialization.SessionSerializer
* @see org.springframework.test.context.ContextConfiguration
* @see org.springframework.test.context.junit4.SpringRunner
* @since 2.1.x
*/ */
@RunWith(SpringRunner.class) @RunWith(SpringRunner.class)
@ContextConfiguration( @ContextConfiguration(
@@ -260,7 +275,7 @@ public class ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegration
this.sessions.put(session.getId(), session); this.sessions.put(session.getId(), session);
if (session instanceof GemFireSession) { if (session instanceof GemFireSession) {
((GemFireSession) session).commit(); ((GemFireSession<?>) session).commit();
} }
} }
@@ -281,11 +296,11 @@ public class ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegration
session.setAttribute("attributeTwo", "testTwo"); session.setAttribute("attributeTwo", "testTwo");
assertThat(session.getAttributeNames()).containsOnly("attributeOne", "attributeTwo"); assertThat(session.getAttributeNames()).containsOnly("attributeOne", "attributeTwo");
assertThat(((GemFireSession) session).hasDelta()).isTrue(); assertThat(((GemFireSession<?>) session).hasDelta()).isTrue();
put(session); put(session);
assertThat(((GemFireSession) session).hasDelta()).isFalse(); assertThat(((GemFireSession<?>) session).hasDelta()).isFalse();
// Reload to (fully) deserialize Session // Reload to (fully) deserialize Session
Session loadedSession = get(session.getId()); Session loadedSession = get(session.getId());
@@ -313,7 +328,7 @@ public class ConcurrentSessionOperationsUsingClientCachingProxyRegionIntegration
assertThat(session.getAttributeNames()).containsOnly("attributeOne", "attributeTwo"); assertThat(session.getAttributeNames()).containsOnly("attributeOne", "attributeTwo");
assertThat(session.<String>getAttribute("attributeOne")).isEqualTo("testOne"); assertThat(session.<String>getAttribute("attributeOne")).isEqualTo("testOne");
assertThat(session.<String>getAttribute("attributeTwo")).isEqualTo("testTwo"); assertThat(session.<String>getAttribute("attributeTwo")).isEqualTo("testTwo");
assertThat(((GemFireSession) session).hasDelta()).isFalse(); assertThat(((GemFireSession<?>) session).hasDelta()).isFalse();
put(session); put(session);
} }