diff --git a/build.gradle b/build.gradle index 70c674b6a0..22cd409982 100644 --- a/build.gradle +++ b/build.gradle @@ -50,7 +50,7 @@ subprojects { subproject -> springAmqpVersion = '1.1.3.RELEASE' springDataMongoVersion = '1.1.1.RELEASE' springDataRedisVersion = '1.0.2.RELEASE' - springGemfireVersion = '1.1.1.RELEASE' + springGemfireVersion = '1.2.2.RELEASE' springSecurityVersion = '3.1.3.RELEASE' springSocialTwitterVersion = '1.0.1.RELEASE' springWsVersion = '2.1.1.RELEASE' diff --git a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/outbound/CacheWritingMessageHandlerTests.java b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/outbound/CacheWritingMessageHandlerTests.java index 1bccd71e11..e2a2d8da5e 100644 --- a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/outbound/CacheWritingMessageHandlerTests.java +++ b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/outbound/CacheWritingMessageHandlerTests.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2011 the original author or authors. + * Copyright 2002-2013 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -18,6 +18,7 @@ package org.springframework.integration.gemfire.outbound; import static org.junit.Assert.assertEquals; +import java.util.Collections; import java.util.HashMap; import java.util.Map; @@ -28,13 +29,13 @@ import org.springframework.data.gemfire.RegionFactoryBean; import org.springframework.integration.Message; import org.springframework.integration.support.MessageBuilder; -import com.gemstone.bp.edu.emory.mathcs.backport.java.util.Collections; import com.gemstone.gemfire.cache.Cache; import com.gemstone.gemfire.cache.Region; /** * @author Mark Fisher * @author David Turanski + * @author Gunnar Hillert * @since 2.1 */ public class CacheWritingMessageHandlerTests { @@ -58,7 +59,7 @@ public class CacheWritingMessageHandlerTests { assertEquals(1, region.size()); assertEquals("bar", region.get("foo")); } - + @Test public void ExpressionsWriteToCache() throws Exception { CacheFactoryBean cacheFactoryBean = new CacheFactoryBean(); @@ -71,13 +72,12 @@ public class CacheWritingMessageHandlerTests { Region region = regionFactoryBean.getObject(); assertEquals(0, region.size()); CacheWritingMessageHandler handler = new CacheWritingMessageHandler(region); - + Map expressions = new HashMap(); expressions.put("'foo'", "'bar'"); expressions.put("payload.toUpperCase()", "headers['bar'].toUpperCase()"); handler.setCacheEntries(expressions); - - @SuppressWarnings("unchecked") + Message message = MessageBuilder.withPayload("foo").copyHeaders(Collections.singletonMap("bar", "bar")).build(); handler.handleMessage(message); assertEquals(2, region.size());