This is an automated email from the ASF dual-hosted git repository. jensdeppe pushed a commit to branch release/1.9.2 in repository https://gitbox.apache.org/repos/asf/geode.git
commit 19103e3c4f1b5e4534e15a266ca73daa0ed9011b Author: nabarun <[email protected]> AuthorDate: Tue Sep 10 01:37:59 2019 -0700 GEODE-7127: Fixing the list AEQ command. * created with paused event processor will correct display the config. --- .../internal/cli/functions/ListAsyncEventQueuesFunction.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/ListAsyncEventQueuesFunction.java b/geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/ListAsyncEventQueuesFunction.java index 25e4517..056a07c 100644 --- a/geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/ListAsyncEventQueuesFunction.java +++ b/geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/ListAsyncEventQueuesFunction.java @@ -25,6 +25,7 @@ import org.apache.geode.cache.asyncqueue.AsyncEventQueue; import org.apache.geode.cache.asyncqueue.internal.AsyncEventQueueImpl; import org.apache.geode.cache.execute.FunctionContext; import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.internal.cache.wan.AbstractGatewaySender; import org.apache.geode.internal.cache.xmlcache.Declarable2; import org.apache.geode.management.cli.CliFunction; import org.apache.geode.management.internal.cli.domain.AsyncEventQueueDetails; @@ -72,6 +73,7 @@ public class ListAsyncEventQueuesFunction extends CliFunction { } private boolean isCreatedWithPausedEventDispatching(AsyncEventQueue queue) { - return ((AsyncEventQueueImpl) queue).getSender().isPaused(); + return ((AbstractGatewaySender) ((AsyncEventQueueImpl) queue).getSender()) + .isStartEventProcessorInPausedState(); } }
