Repository: geode Updated Branches: refs/heads/develop be4551191 -> 31e82d6d6
http://git-wip-us.apache.org/repos/asf/geode/blob/530f48f3/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionNamesRequestOperationHandlerJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionNamesRequestOperationHandlerJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionNamesRequestOperationHandlerJUnitTest.java index 29902e6..fd84d41 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionNamesRequestOperationHandlerJUnitTest.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionNamesRequestOperationHandlerJUnitTest.java @@ -17,7 +17,6 @@ package org.apache.geode.protocol.protobuf.operations; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; -import java.nio.charset.Charset; import java.util.Arrays; import java.util.Collections; import java.util.HashSet; @@ -28,7 +27,8 @@ import org.junit.experimental.categories.Category; import org.apache.geode.cache.Cache; import org.apache.geode.cache.Region; -import org.apache.geode.protocol.protobuf.BasicTypes; +import org.apache.geode.internal.cache.tier.sockets.ExecutionContext; +import org.apache.geode.internal.cache.tier.sockets.InvalidExecutionContextException; import org.apache.geode.protocol.protobuf.RegionAPI; import org.apache.geode.protocol.protobuf.Result; import org.apache.geode.protocol.protobuf.Success; @@ -62,11 +62,12 @@ public class GetRegionNamesRequestOperationHandlerJUnitTest extends OperationHan } @Test - public void processReturnsCacheRegions() throws CodecAlreadyRegisteredForTypeException, - UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { - Result<RegionAPI.GetRegionNamesResponse> result = - operationHandler.process(serializationServiceStub, - ProtobufRequestUtilities.createGetRegionNamesRequest(), cacheStub); + public void processReturnsCacheRegions() + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException, InvalidExecutionContextException { + Result<RegionAPI.GetRegionNamesResponse> result = operationHandler.process( + serializationServiceStub, ProtobufRequestUtilities.createGetRegionNamesRequest(), + new ExecutionContext(cacheStub)); Assert.assertTrue(result instanceof Success); RegionAPI.GetRegionNamesResponse getRegionsResponse = result.getMessage(); @@ -84,14 +85,15 @@ public class GetRegionNamesRequestOperationHandlerJUnitTest extends OperationHan } @Test - public void processReturnsNoCacheRegions() throws CodecAlreadyRegisteredForTypeException, - UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + public void processReturnsNoCacheRegions() + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException, InvalidExecutionContextException { Cache emptyCache = mock(Cache.class);; when(emptyCache.rootRegions()) .thenReturn(Collections.unmodifiableSet(new HashSet<Region<String, String>>())); - Result<RegionAPI.GetRegionNamesResponse> result = - operationHandler.process(serializationServiceStub, - ProtobufRequestUtilities.createGetRegionNamesRequest(), emptyCache); + Result<RegionAPI.GetRegionNamesResponse> result = operationHandler.process( + serializationServiceStub, ProtobufRequestUtilities.createGetRegionNamesRequest(), + new ExecutionContext(emptyCache)); Assert.assertTrue(result instanceof Success); RegionAPI.GetRegionNamesResponse getRegionsResponse = result.getMessage(); http://git-wip-us.apache.org/repos/asf/geode/blob/530f48f3/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionRequestOperationHandlerJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionRequestOperationHandlerJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionRequestOperationHandlerJUnitTest.java index 5cfa6b3..6762f66 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionRequestOperationHandlerJUnitTest.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRegionRequestOperationHandlerJUnitTest.java @@ -19,6 +19,8 @@ import org.apache.geode.cache.DataPolicy; import org.apache.geode.cache.Region; import org.apache.geode.cache.RegionAttributes; import org.apache.geode.cache.Scope; +import org.apache.geode.internal.cache.tier.sockets.ExecutionContext; +import org.apache.geode.internal.cache.tier.sockets.InvalidExecutionContextException; import org.apache.geode.protocol.MessageUtil; import org.apache.geode.protocol.protobuf.BasicTypes; import org.apache.geode.protocol.protobuf.ClientProtocol; @@ -57,8 +59,9 @@ public class GetRegionRequestOperationHandlerJUnitTest extends OperationHandlerJ } @Test - public void processReturnsCacheRegions() throws CodecAlreadyRegisteredForTypeException, - UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + public void processReturnsCacheRegions() + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException, InvalidExecutionContextException { RegionAttributes regionAttributesStub = mock(RegionAttributes.class); when(cacheStub.getRegion(TEST_REGION1)).thenReturn(region1Stub); @@ -72,7 +75,7 @@ public class GetRegionRequestOperationHandlerJUnitTest extends OperationHandlerJ Result<RegionAPI.GetRegionResponse> result = operationHandler.process(serializationServiceStub, - MessageUtil.makeGetRegionRequest(TEST_REGION1), cacheStub); + MessageUtil.makeGetRegionRequest(TEST_REGION1), new ExecutionContext(cacheStub)); RegionAPI.GetRegionResponse response = result.getMessage(); BasicTypes.Region region = response.getRegion(); Assert.assertEquals(TEST_REGION1, region.getName()); @@ -89,14 +92,15 @@ public class GetRegionRequestOperationHandlerJUnitTest extends OperationHandlerJ } @Test - public void processReturnsNoCacheRegions() throws CodecAlreadyRegisteredForTypeException, - UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + public void processReturnsNoCacheRegions() + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException, InvalidExecutionContextException { Cache emptyCache = mock(Cache.class); when(emptyCache.rootRegions()) .thenReturn(Collections.unmodifiableSet(new HashSet<Region<String, String>>())); String unknownRegionName = "UNKNOWN_REGION"; Result<RegionAPI.GetRegionResponse> result = operationHandler.process(serializationServiceStub, - MessageUtil.makeGetRegionRequest(unknownRegionName), emptyCache); + MessageUtil.makeGetRegionRequest(unknownRegionName), new ExecutionContext(emptyCache)); Assert.assertTrue(result instanceof Failure); Assert.assertEquals(ProtocolErrorCode.REGION_NOT_FOUND.codeValue, result.getErrorMessage().getError().getErrorCode()); http://git-wip-us.apache.org/repos/asf/geode/blob/530f48f3/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java index 0213bf7..af35f6b 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java @@ -16,6 +16,8 @@ package org.apache.geode.protocol.protobuf.operations; import com.google.protobuf.ByteString; import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.tier.sockets.ExecutionContext; +import org.apache.geode.internal.cache.tier.sockets.InvalidExecutionContextException; import org.apache.geode.protocol.protobuf.BasicTypes; import org.apache.geode.protocol.protobuf.Failure; import org.apache.geode.protocol.protobuf.ProtocolErrorCode; @@ -70,10 +72,10 @@ public class GetRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe @Test public void processReturnsTheEncodedValueFromTheRegion() throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException { + CodecNotRegisteredForTypeException, InvalidExecutionContextException { RegionAPI.GetRequest getRequest = generateTestRequest(false, false, false); - Result<RegionAPI.GetResponse> result = - operationHandler.process(serializationServiceStub, getRequest, cacheStub); + Result<RegionAPI.GetResponse> result = operationHandler.process(serializationServiceStub, + getRequest, new ExecutionContext(cacheStub)); Assert.assertTrue(result instanceof Success); Assert.assertEquals(BasicTypes.EncodedValue.ValueCase.STRINGRESULT, @@ -85,10 +87,10 @@ public class GetRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe @Test public void processReturnsUnsucessfulResponseForInvalidRegion() throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException { + CodecNotRegisteredForTypeException, InvalidExecutionContextException { RegionAPI.GetRequest getRequest = generateTestRequest(true, false, false); - Result<RegionAPI.GetResponse> response = - operationHandler.process(serializationServiceStub, getRequest, cacheStub); + Result<RegionAPI.GetResponse> response = operationHandler.process(serializationServiceStub, + getRequest, new ExecutionContext(cacheStub)); Assert.assertTrue(response instanceof Failure); Assert.assertEquals(ProtocolErrorCode.REGION_NOT_FOUND.codeValue, @@ -98,10 +100,10 @@ public class GetRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe @Test public void processReturnsKeyNotFoundWhenKeyIsNotFound() throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException { + CodecNotRegisteredForTypeException, InvalidExecutionContextException { RegionAPI.GetRequest getRequest = generateTestRequest(false, true, false); - Result<RegionAPI.GetResponse> response = - operationHandler.process(serializationServiceStub, getRequest, cacheStub); + Result<RegionAPI.GetResponse> response = operationHandler.process(serializationServiceStub, + getRequest, new ExecutionContext(cacheStub)); Assert.assertTrue(response instanceof Success); } @@ -109,10 +111,10 @@ public class GetRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe @Test public void processReturnsLookupFailureWhenKeyFoundWithNoValue() throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException { + CodecNotRegisteredForTypeException, InvalidExecutionContextException { RegionAPI.GetRequest getRequest = generateTestRequest(false, false, true); - Result<RegionAPI.GetResponse> response = - operationHandler.process(serializationServiceStub, getRequest, cacheStub); + Result<RegionAPI.GetResponse> response = operationHandler.process(serializationServiceStub, + getRequest, new ExecutionContext(cacheStub)); Assert.assertTrue(response instanceof Success); } @@ -120,7 +122,8 @@ public class GetRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe @Test public void processReturnsErrorWhenUnableToDecodeRequest() throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException, UnsupportedEncodingException { + CodecNotRegisteredForTypeException, UnsupportedEncodingException, + InvalidExecutionContextException { CodecNotRegisteredForTypeException exception = new CodecNotRegisteredForTypeException("error finding codec for type"); when(serializationServiceStub.decode(any(), any())).thenThrow(exception); @@ -132,8 +135,8 @@ public class GetRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe .setCustomEncodedValue(customEncodedValueBuilder).build(); RegionAPI.GetRequest getRequest = ProtobufRequestUtilities.createGetRequest(TEST_REGION, encodedKey).getGetRequest(); - Result<RegionAPI.GetResponse> response = - operationHandler.process(serializationServiceStub, getRequest, cacheStub); + Result<RegionAPI.GetResponse> response = operationHandler.process(serializationServiceStub, + getRequest, new ExecutionContext(cacheStub)); Assert.assertTrue(response instanceof Failure); Assert.assertEquals(ProtocolErrorCode.VALUE_ENCODING_ERROR.codeValue, http://git-wip-us.apache.org/repos/asf/geode/blob/530f48f3/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutAllRequestOperationHandlerJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutAllRequestOperationHandlerJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutAllRequestOperationHandlerJUnitTest.java index c13d542..d3fff49 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutAllRequestOperationHandlerJUnitTest.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutAllRequestOperationHandlerJUnitTest.java @@ -15,6 +15,8 @@ package org.apache.geode.protocol.protobuf.operations; import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.tier.sockets.ExecutionContext; +import org.apache.geode.internal.cache.tier.sockets.InvalidExecutionContextException; import org.apache.geode.protocol.protobuf.BasicTypes; import org.apache.geode.protocol.protobuf.RegionAPI; import org.apache.geode.protocol.protobuf.Result; @@ -66,12 +68,13 @@ public class PutAllRequestOperationHandlerJUnitTest extends OperationHandlerJUni } @Test - public void processInsertsMultipleValidEntriesInCache() throws UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException, CodecAlreadyRegisteredForTypeException { + public void processInsertsMultipleValidEntriesInCache() + throws UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException, + CodecAlreadyRegisteredForTypeException, InvalidExecutionContextException { PutAllRequestOperationHandler operationHandler = new PutAllRequestOperationHandler(); Result<RegionAPI.PutAllResponse> result = operationHandler.process(serializationServiceStub, - generateTestRequest(false, true), cacheStub); + generateTestRequest(false, true), new ExecutionContext(cacheStub)); Assert.assertTrue(result instanceof Success); @@ -85,7 +88,7 @@ public class PutAllRequestOperationHandlerJUnitTest extends OperationHandlerJUni PutAllRequestOperationHandler operationHandler = new PutAllRequestOperationHandler(); Result<RegionAPI.PutAllResponse> result = operationHandler.process(serializationServiceStub, - generateTestRequest(true, true), cacheStub); + generateTestRequest(true, true), new ExecutionContext(cacheStub)); assertTrue(result instanceof Success); verify(regionMock).put(TEST_KEY1, TEST_VALUE1); @@ -104,7 +107,7 @@ public class PutAllRequestOperationHandlerJUnitTest extends OperationHandlerJUni PutAllRequestOperationHandler operationHandler = new PutAllRequestOperationHandler(); Result<RegionAPI.PutAllResponse> result = operationHandler.process(serializationServiceStub, - generateTestRequest(false, false), cacheStub); + generateTestRequest(false, false), new ExecutionContext(cacheStub)); assertTrue(result instanceof Success); http://git-wip-us.apache.org/repos/asf/geode/blob/530f48f3/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandlerJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandlerJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandlerJUnitTest.java index fc697e4..64d9f67 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandlerJUnitTest.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandlerJUnitTest.java @@ -16,6 +16,8 @@ package org.apache.geode.protocol.protobuf.operations; import com.google.protobuf.ByteString; import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.tier.sockets.ExecutionContext; +import org.apache.geode.internal.cache.tier.sockets.InvalidExecutionContextException; import org.apache.geode.protocol.protobuf.BasicTypes; import org.apache.geode.protocol.protobuf.Failure; import org.apache.geode.protocol.protobuf.ProtocolErrorCode; @@ -61,11 +63,12 @@ public class PutRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe } @Test - public void test_puttingTheEncodedEntryIntoRegion() throws UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException, CodecAlreadyRegisteredForTypeException { + public void test_puttingTheEncodedEntryIntoRegion() + throws UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException, + CodecAlreadyRegisteredForTypeException, InvalidExecutionContextException { PutRequestOperationHandler operationHandler = new PutRequestOperationHandler(); - Result<RegionAPI.PutResponse> result = - operationHandler.process(serializationServiceStub, generateTestRequest(), cacheStub); + Result<RegionAPI.PutResponse> result = operationHandler.process(serializationServiceStub, + generateTestRequest(), new ExecutionContext(cacheStub)); assertTrue(result instanceof Success); @@ -74,9 +77,9 @@ public class PutRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe } @Test - public void test_invalidEncodingType() - throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException, UnsupportedEncodingException { + public void test_invalidEncodingType() throws CodecAlreadyRegisteredForTypeException, + UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException, + UnsupportedEncodingException, InvalidExecutionContextException { String exceptionText = "unsupported type!"; UnsupportedEncodingTypeException exception = new UnsupportedEncodingTypeException(exceptionText); @@ -95,8 +98,8 @@ public class PutRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe BasicTypes.Entry testEntry = ProtobufUtilities.createEntry(encodedKey, testValue); RegionAPI.PutRequest putRequest = ProtobufRequestUtilities.createPutRequest(TEST_REGION, testEntry).getPutRequest(); - Result<RegionAPI.PutResponse> result = - operationHandler.process(serializationServiceStub, putRequest, cacheStub); + Result<RegionAPI.PutResponse> result = operationHandler.process(serializationServiceStub, + putRequest, new ExecutionContext(cacheStub)); assertTrue(result instanceof Failure); assertEquals(ProtocolErrorCode.VALUE_ENCODING_ERROR.codeValue, @@ -104,12 +107,13 @@ public class PutRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe } @Test - public void test_RegionNotFound() throws CodecAlreadyRegisteredForTypeException, - UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + public void test_RegionNotFound() + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException, InvalidExecutionContextException { when(cacheStub.getRegion(TEST_REGION)).thenReturn(null); PutRequestOperationHandler operationHandler = new PutRequestOperationHandler(); - Result<RegionAPI.PutResponse> result = - operationHandler.process(serializationServiceStub, generateTestRequest(), cacheStub); + Result<RegionAPI.PutResponse> result = operationHandler.process(serializationServiceStub, + generateTestRequest(), new ExecutionContext(cacheStub)); assertTrue(result instanceof Failure); assertEquals(ProtocolErrorCode.REGION_NOT_FOUND.codeValue, @@ -117,13 +121,14 @@ public class PutRequestOperationHandlerJUnitTest extends OperationHandlerJUnitTe } @Test - public void test_RegionThrowsClasscastException() throws CodecAlreadyRegisteredForTypeException, - UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + public void test_RegionThrowsClasscastException() + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException, InvalidExecutionContextException { when(regionMock.put(any(), any())).thenThrow(ClassCastException.class); PutRequestOperationHandler operationHandler = new PutRequestOperationHandler(); - Result<RegionAPI.PutResponse> result = - operationHandler.process(serializationServiceStub, generateTestRequest(), cacheStub); + Result<RegionAPI.PutResponse> result = operationHandler.process(serializationServiceStub, + generateTestRequest(), new ExecutionContext(cacheStub)); assertTrue(result instanceof Failure); assertEquals(ProtocolErrorCode.CONSTRAINT_VIOLATION.codeValue, http://git-wip-us.apache.org/repos/asf/geode/blob/530f48f3/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/RemoveRequestOperationHandlerJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/RemoveRequestOperationHandlerJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/RemoveRequestOperationHandlerJUnitTest.java index 3b917b7..47d6231 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/RemoveRequestOperationHandlerJUnitTest.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/RemoveRequestOperationHandlerJUnitTest.java @@ -16,6 +16,8 @@ package org.apache.geode.protocol.protobuf.operations; import com.google.protobuf.ByteString; import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.tier.sockets.ExecutionContext; +import org.apache.geode.internal.cache.tier.sockets.InvalidExecutionContextException; import org.apache.geode.protocol.protobuf.BasicTypes; import org.apache.geode.protocol.protobuf.ClientProtocol; import org.apache.geode.protocol.protobuf.Failure; @@ -71,10 +73,10 @@ public class RemoveRequestOperationHandlerJUnitTest extends OperationHandlerJUni @Test public void processValidKeyRemovesTheEntryAndReturnSuccess() throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException { + CodecNotRegisteredForTypeException, InvalidExecutionContextException { RegionAPI.RemoveRequest removeRequest = generateTestRequest(false, false).getRemoveRequest(); - Result<RegionAPI.RemoveResponse> result = - operationHandler.process(serializationServiceStub, removeRequest, cacheStub); + Result<RegionAPI.RemoveResponse> result = operationHandler.process(serializationServiceStub, + removeRequest, new ExecutionContext(cacheStub)); assertTrue(result instanceof Success); verify(regionStub).remove(TEST_KEY); @@ -83,10 +85,10 @@ public class RemoveRequestOperationHandlerJUnitTest extends OperationHandlerJUni @Test public void processReturnsUnsucessfulResponseForInvalidRegion() throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException { + CodecNotRegisteredForTypeException, InvalidExecutionContextException { RegionAPI.RemoveRequest removeRequest = generateTestRequest(true, false).getRemoveRequest(); - Result<RegionAPI.RemoveResponse> result = - operationHandler.process(serializationServiceStub, removeRequest, cacheStub); + Result<RegionAPI.RemoveResponse> result = operationHandler.process(serializationServiceStub, + removeRequest, new ExecutionContext(cacheStub)); assertTrue(result instanceof Failure); assertEquals(ProtocolErrorCode.REGION_NOT_FOUND.codeValue, @@ -96,10 +98,10 @@ public class RemoveRequestOperationHandlerJUnitTest extends OperationHandlerJUni @Test public void processReturnsSuccessWhenKeyIsNotFound() throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException { + CodecNotRegisteredForTypeException, InvalidExecutionContextException { RegionAPI.RemoveRequest removeRequest = generateTestRequest(false, true).getRemoveRequest(); - Result<RegionAPI.RemoveResponse> result = - operationHandler.process(serializationServiceStub, removeRequest, cacheStub); + Result<RegionAPI.RemoveResponse> result = operationHandler.process(serializationServiceStub, + removeRequest, new ExecutionContext(cacheStub)); assertTrue(result instanceof Success); } @@ -107,7 +109,8 @@ public class RemoveRequestOperationHandlerJUnitTest extends OperationHandlerJUni @Test public void processReturnsErrorWhenUnableToDecodeRequest() throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, - CodecNotRegisteredForTypeException, UnsupportedEncodingException { + CodecNotRegisteredForTypeException, UnsupportedEncodingException, + InvalidExecutionContextException { CodecNotRegisteredForTypeException exception = new CodecNotRegisteredForTypeException("error finding codec for type"); when(serializationServiceStub.decode(any(), any())).thenThrow(exception); @@ -120,8 +123,8 @@ public class RemoveRequestOperationHandlerJUnitTest extends OperationHandlerJUni RegionAPI.RemoveRequest removeRequest = ProtobufRequestUtilities.createRemoveRequest(TEST_REGION, encodedKey).getRemoveRequest();; - Result<RegionAPI.RemoveResponse> result = - operationHandler.process(serializationServiceStub, removeRequest, cacheStub); + Result<RegionAPI.RemoveResponse> result = operationHandler.process(serializationServiceStub, + removeRequest, new ExecutionContext(cacheStub)); assertTrue(result instanceof Failure); assertEquals(ProtocolErrorCode.VALUE_ENCODING_ERROR.codeValue,
