You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bo...@apache.org on 2019/11/16 00:43:52 UTC

[geode] 01/01: GEODE-7465: Set eventProcessor to null in serial AEQ when it is stopped

This is an automated email from the ASF dual-hosted git repository.

boglesby pushed a commit to branch feature/GEODE-7465
in repository https://gitbox.apache.org/repos/asf/geode.git

commit 4ecfd6810715f222cb64e1ae960f8bd39c983b85
Author: Barry Oglesby <bo...@pivotal.io>
AuthorDate: Fri Nov 15 16:40:14 2019 -0800

    GEODE-7465: Set eventProcessor to null in serial AEQ when it is stopped
---
 .../geode/cache/asyncqueue/internal/SerialAsyncEventQueueImpl.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/SerialAsyncEventQueueImpl.java b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/SerialAsyncEventQueueImpl.java
index de2a2d7..59a1311 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/SerialAsyncEventQueueImpl.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/SerialAsyncEventQueueImpl.java
@@ -177,12 +177,15 @@ public class SerialAsyncEventQueueImpl extends AbstractGatewaySender {
     InternalDistributedSystem system =
         (InternalDistributedSystem) this.cache.getDistributedSystem();
     system.handleResourceEvent(ResourceEvent.GATEWAYSENDER_STOP, this);
+
+    this.eventProcessor = null;
   }
 
   @Override
   public String toString() {
     StringBuffer sb = new StringBuffer();
-    sb.append("SerialGatewaySender{");
+    sb.append(getClass().getSimpleName());
+    sb.append("{");
     sb.append("id=" + getId());
     sb.append(",remoteDsId=" + getRemoteDSId());
     sb.append(",isRunning =" + isRunning());