This is an automated email from the ASF dual-hosted git repository. dschneider pushed a commit to branch feature/GEODE-6068 in repository https://gitbox.apache.org/repos/asf/geode.git
commit 8ca188621817f94c8916ad20b1776359653caa7d Author: Darrel Schneider <dschnei...@pivotal.io> AuthorDate: Fri Nov 16 13:00:03 2018 -0800 added stop and destroy to InternalAsyncEventQueue interface --- .../apache/geode/cache/asyncqueue/internal/AsyncEventQueueImpl.java | 2 ++ .../geode/cache/asyncqueue/internal/InternalAsyncEventQueue.java | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/AsyncEventQueueImpl.java b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/AsyncEventQueueImpl.java index 55c4027..ae93b0a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/AsyncEventQueueImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/AsyncEventQueueImpl.java @@ -169,12 +169,14 @@ public class AsyncEventQueueImpl implements InternalAsyncEventQueue { return sender.getIsMetaQueue(); } + @Override public void stop() { if (sender.isRunning()) { sender.stop(); } } + @Override public void destroy() { destroy(true); } diff --git a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/InternalAsyncEventQueue.java b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/InternalAsyncEventQueue.java index 73afa36..fd350a3 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/InternalAsyncEventQueue.java +++ b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/InternalAsyncEventQueue.java @@ -24,4 +24,8 @@ public interface InternalAsyncEventQueue extends AsyncEventQueue { InternalGatewaySender getSender(); AsyncEventQueueStats getStatistics(); + + void stop(); + + void destroy(); }