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

Add generic signature to getSessionRepository().

Browse Source 
Add commit(:Session) method.
This commit is contained in:
John Blum
2018-12-19 02:17:27 -08:00
parent b077f66856
commit 23da21d8fe
2 changed files with 18 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -291,8 +291,9 @@ public abstract class AbstractGemFireIntegrationTests extends ForkingClientServe
}
@Nullable
protected SessionRepository<Session> getSessionRepository() {
return this.sessionRepository;
@SuppressWarnings("unchecked")
protected <S extends Session, T extends SessionRepository<S>> T getSessionRepository() {
return (T) this.sessionRepository;
}
protected void assertValidSession(Session session) {
@@ -347,6 +348,16 @@ public abstract class AbstractGemFireIntegrationTests extends ForkingClientServe
return enableQueryDebugging();
}
@SuppressWarnings("unchecked")
protected <T extends Session> T commit(T session) {
return Optional.ofNullable(getSessionRepository())
.filter(AbstractGemFireOperationsSessionRepository.class::isInstance)
.map(AbstractGemFireOperationsSessionRepository.class::cast)
.map(it -> (T) it.commit(session))
.orElse(session);
}
@SuppressWarnings("unchecked")
protected <T extends Session> T createSession() {

6
spring-session-data-geode/src/integration-test/java/org/springframework/session/data/gemfire/expiration/LazyTimeoutSessionExpirationIntegrationTests.java
View File

@@ -27,6 +27,7 @@ import org.springframework.context.annotation.Bean;
import org.springframework.data.gemfire.config.annotation.PeerCacheApplication;
import org.springframework.data.gemfire.tests.mock.annotation.EnableGemFireMockObjects;
import org.springframework.session.Session;
import org.springframework.session.SessionRepository;
import org.springframework.session.data.gemfire.AbstractGemFireIntegrationTests;
import org.springframework.session.data.gemfire.config.annotation.web.http.EnableGemFireHttpSession;
import org.springframework.session.data.gemfire.expiration.config.FixedDurationExpirationSessionRepositoryBeanPostProcessor;
@@ -57,8 +58,11 @@ import org.springframework.test.context.junit4.SpringRunner;
public class LazyTimeoutSessionExpirationIntegrationTests extends AbstractGemFireIntegrationTests {
@Test
@SuppressWarnings("unchecked")
public void sessionRepositoryIsAFixedDurationExpirationSessionRepository() {
assertThat(getSessionRepository()).isInstanceOf(FixedDurationExpirationSessionRepository.class);
assertThat(this.<Session, SessionRepository>getSessionRepository())
.isInstanceOf(FixedDurationExpirationSessionRepository.class);
}
@Test