From 9a091376528cd79c978bc5b3019d30256fcf3fd5 Mon Sep 17 00:00:00 2001 From: John Blum Date: Wed, 30 Oct 2019 20:36:14 -0700 Subject: [PATCH] Fix bug in the mocking support for AEQ resume event dispatching. Additionally, add mocking behavior for o.a.g.cache.asyncqueue.AsyncEventQueue.isDipatchingEnabled(). --- .../data/gemfire/tests/mock/GemFireMockObjectsSupport.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java b/spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java index f0cd772..39e1e99 100644 --- a/spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java +++ b/spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java @@ -876,6 +876,7 @@ public abstract class GemFireMockObjectsSupport extends MockObjectsSupport { when(mockAsyncEventQueue.isBatchConflationEnabled()).thenAnswer(newGetter(batchConflationEnabled)); when(mockAsyncEventQueue.isDiskSynchronous()).thenAnswer(newGetter(diskSynchronous)); + when(mockAsyncEventQueue.isDispatchingPaused()).thenAnswer(newGetter(pauseEventDispatching)); when(mockAsyncEventQueue.isForwardExpirationDestroy()).thenAnswer(newGetter(forwardExpirationDestroy)); when(mockAsyncEventQueue.isParallel()).thenAnswer(newGetter(parallel)); when(mockAsyncEventQueue.isPersistent()).thenAnswer(newGetter(persistent)); @@ -892,7 +893,8 @@ public abstract class GemFireMockObjectsSupport extends MockObjectsSupport { when(mockAsyncEventQueue.getMaximumQueueMemory()).thenAnswer(newGetter(maximumQueueMemory)); when(mockAsyncEventQueue.getOrderPolicy()).thenAnswer(newGetter(orderPolicy)); - doAnswer(newGetter(pauseEventDispatching)).when(mockAsyncEventQueue).resumeEventDispatching(); + doAnswer(newSetter(pauseEventDispatching, false, null)) + .when(mockAsyncEventQueue).resumeEventDispatching(); when(mockAsyncEventQueue.size()).thenReturn(0);