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

Optimize imports.

Browse Source 
Annotate SpyingDataSerializableSessionSerializer class's serialize(..) and deserialize(..) methods with @SuppressWarnings('rawtypes').

Apply wildcard generic type signature to GemFireSession type parameters.

Remove unnecessary @SuppressWarnings('all') annotation.
This commit is contained in:
John Blum
2020-02-04 20:14:09 -08:00
parent f02521a6b9
commit ca4ec497aa
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -39,12 +39,14 @@ import java.util.concurrent.Future;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;
import org.apache.geode.cache.DataPolicy;
import org.apache.geode.cache.client.ClientRegionShortcut;
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.apache.geode.cache.DataPolicy;
import org.apache.geode.cache.client.ClientRegionShortcut;
import org.springframework.context.annotation.AnnotationConfigApplicationContext; import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.data.gemfire.config.annotation.CacheServerApplication; import org.springframework.data.gemfire.config.annotation.CacheServerApplication;
@@ -217,7 +219,6 @@ public class MultiThreadedHighlyConcurrentClientServerHttpSessionAccessIntegrati
}; };
} }
@SuppressWarnings("all")
private Callable<Integer> newRemoveSessionAttributeTask() { private Callable<Integer> newRemoveSessionAttributeTask() {
return () -> { return () -> {
@@ -371,7 +372,7 @@ public class MultiThreadedHighlyConcurrentClientServerHttpSessionAccessIntegrati
} }
static class SpyingDataSerializableSessionSerializer static class SpyingDataSerializableSessionSerializer
extends AbstractDataSerializableSessionSerializer<GemFireSession> { extends AbstractDataSerializableSessionSerializer<GemFireSession<?>> {
private static final AtomicInteger serializationCount = new AtomicInteger(0); private static final AtomicInteger serializationCount = new AtomicInteger(0);
@@ -392,7 +393,7 @@ public class MultiThreadedHighlyConcurrentClientServerHttpSessionAccessIntegrati
} }
@Override @Override
@SuppressWarnings("unchecked") @SuppressWarnings({ "rawtypes", "unchecked" })
public void serialize(GemFireSession session, DataOutput dataOutput) { public void serialize(GemFireSession session, DataOutput dataOutput) {
assertThat(session).isInstanceOf(DeltaCapableGemFireSession.class); assertThat(session).isInstanceOf(DeltaCapableGemFireSession.class);
@@ -404,6 +405,7 @@ public class MultiThreadedHighlyConcurrentClientServerHttpSessionAccessIntegrati
} }
@Override @Override
@SuppressWarnings("rawtypes")
public GemFireSession deserialize(DataInput dataInput) { public GemFireSession deserialize(DataInput dataInput) {
return this.sessionSerializer.deserialize(dataInput); return this.sessionSerializer.deserialize(dataInput);
} }