activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [65/67] [abbrv] activemq-artemis git commit: fixing slow consumer
Date Sat, 19 Mar 2016 05:09:11 GMT
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 <clebertsuconic@apache.org>
Authored: Fri Mar 18 15:01:00 2016 -0400
Committer: Clebert Suconic <clebertsuconic@apache.org>
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


Mime
View raw message