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