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

Add additional assertions and optimize imports.

Browse Source
This commit is contained in:
John Blum
2019-11-15 18:41:45 -08:00
parent 91b3ab747e
commit 91e0fa4371
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
spring-geode-autoconfigure/src/test/java/org/springframework/geode/boot/autoconfigure/session/AutoConfiguredSessionRemoteCachingIntegrationTests.java
View File

@@ -24,15 +24,15 @@ import java.util.concurrent.atomic.AtomicReference;
import javax.annotation.Resource;
import javax.servlet.http.HttpSession;
import org.apache.geode.cache.DataPolicy;
import org.apache.geode.cache.Region;
import org.apache.geode.cache.client.ClientCache;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.apache.geode.cache.DataPolicy;
import org.apache.geode.cache.Region;
import org.apache.geode.cache.client.ClientCache;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.WebApplicationType;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -86,6 +86,7 @@ import org.springframework.web.client.RestTemplate;
* @see org.springframework.web.client.RestTemplate
* @since 1.0.0
*/
@ActiveProfiles("session-remote")
@RunWith(SpringRunner.class)
@SpringBootTest(
classes = {
@@ -98,7 +99,6 @@ import org.springframework.web.client.RestTemplate;
},
webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT
)
@ActiveProfiles("session-remote")
@SuppressWarnings("unused")
public class AutoConfiguredSessionRemoteCachingIntegrationTests extends ForkingClientServerIntegrationTestsSupport {
@@ -155,9 +155,14 @@ public class AutoConfiguredSessionRemoteCachingIntegrationTests extends ForkingC
assertThat(response.getBody()).isEqualTo("SUCCESS");
//System.err.printf("HTTP RESPONSE HEADERS [%s]%n", response.getHeaders());
String httpHeaderWithSessionId =
StringUtils.collectionToCommaDelimitedString(response.getHeaders().get(HTTP_HEADER_AUTHENTICATION_INFO));
assertThat(httpHeaderWithSessionId).contains(sessionId.get());
assertThat(this.sessionsRegion.keySetOnServer()).containsExactlyInAnyOrder(sessionId.get());
RequestEntity<Void> request = RequestEntity
.get(URI.create(url.concat("/getter?name=MyKey")))
.header(HTTP_HEADER_AUTHENTICATION_INFO, httpHeaderWithSessionId)
@@ -176,7 +181,6 @@ public class AutoConfiguredSessionRemoteCachingIntegrationTests extends ForkingC
HttpSessionIdResolver headerHttpSessionIdResolver() {
return HeaderHttpSessionIdResolver.authenticationInfo();
}
}
@RestController
@@ -184,7 +188,8 @@ public class AutoConfiguredSessionRemoteCachingIntegrationTests extends ForkingC
static class TestWebApplication {
@GetMapping("/attribute/setter")
public String setSessionAttribute(HttpSession session, @RequestParam("name") String name, String value) {
public String setSessionAttribute(HttpSession session,
@RequestParam("name") String name, @RequestParam("value") String value) {
assertThat(session).isNotNull();
assertThat(session.getClass().getPackage().getName()).startsWith("org.springframework.session");