[geode] 01/02: added stop and destroy to InternalAsyncEventQueue interface

[ds...@apache.org]

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 <ds...@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();
 }