[geode] branch feature/GEODE-7465 created (now 4ecfd68)

[bo...@apache.org]

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

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


      at 4ecfd68  GEODE-7465: Set eventProcessor to null in serial AEQ when it is stopped

This branch includes the following new commits:

     new 4ecfd68  GEODE-7465: Set eventProcessor to null in serial AEQ when it is stopped

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

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

[bo...@apache.org]

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());