fixing slow consumer
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/1ca8967a Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/1ca8967a Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/1ca8967a Branch: refs/heads/refactor-openwire Commit: 1ca8967a38633959e657b4619c1029c4a63e2dea Parents: 9e206ad Author: Clebert Suconic <[email protected]> Authored: Fri Mar 18 15:01:00 2016 -0400 Committer: Clebert Suconic <[email protected]> Committed: Sat Mar 19 01:07:37 2016 -0400 ---------------------------------------------------------------------- .../activemq/artemis/core/server/impl/ServerConsumerImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1ca8967a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java ---------------------------------------------------------------------- diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java index 298bf5f..14f22ed 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java @@ -242,7 +242,9 @@ public class ServerConsumerImpl implements ServerConsumer, ReadyListener { @Override public void fireSlowConsumer() { - slowConsumerListener.onSlowConsumer(this); + if (slowConsumerListener != null) { + slowConsumerListener.onSlowConsumer(this); + } } @Override
