diff --git a/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/AbstractGeodeSecurityIntegrationTests.java b/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/AbstractGeodeSecurityIntegrationTests.java
index 1e3a834c..6cb9c105 100644
--- a/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/AbstractGeodeSecurityIntegrationTests.java
+++ b/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/AbstractGeodeSecurityIntegrationTests.java
@@ -248,7 +248,7 @@ public abstract class AbstractGeodeSecurityIntegrationTests extends ForkingClien
 
 		CacheLoader<String, String> echoCacheLoader() {
 
-			return new CacheLoader<String, String>() {
+			return new CacheLoader<>() {
 
 				@Override
 				public String load(LoaderHelper<String, String> helper) throws CacheLoaderException {
diff --git a/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/EnableContinuousQueriesConfigurationIntegrationTests.java b/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/EnableContinuousQueriesConfigurationIntegrationTests.java
index 0751c92b..f7d3a764 100644
--- a/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/EnableContinuousQueriesConfigurationIntegrationTests.java
+++ b/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/EnableContinuousQueriesConfigurationIntegrationTests.java
@@ -163,7 +163,7 @@ public class EnableContinuousQueriesConfigurationIntegrationTests extends Forkin
 
 		private CacheListener<Long, TemperatureReading> temperatureReadingCounterListener() {
 
-			return new CacheListenerAdapter<Long, TemperatureReading>() {
+			return new CacheListenerAdapter<>() {
 
 				@Override
 				public void afterCreate(EntryEvent<Long, TemperatureReading> event) {
@@ -198,7 +198,7 @@ public class EnableContinuousQueriesConfigurationIntegrationTests extends Forkin
 
 		private CacheLoader<Long, TemperatureReading> temperatureReadingsLoader() {
 
-			return new CacheLoader<Long, TemperatureReading>() {
+			return new CacheLoader<>() {
 
 				@Override
 				public TemperatureReading load(LoaderHelper<Long, TemperatureReading> helper) throws CacheLoaderException {