You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2014/10/03 00:37:35 UTC
git commit: check for nulls
Repository: incubator-usergrid
Updated Branches:
refs/heads/two-dot-o bd3907a60 -> ae9c9c05e
check for nulls
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/ae9c9c05
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/ae9c9c05
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/ae9c9c05
Branch: refs/heads/two-dot-o
Commit: ae9c9c05eda7d9bc324f1d7c3e26acfe2430ba04
Parents: bd3907a
Author: Shawn Feldman <sf...@apache.org>
Authored: Thu Oct 2 16:37:16 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Thu Oct 2 16:37:16 2014 -0600
----------------------------------------------------------------------
.../org/apache/usergrid/services/notifications/QueueListener.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/ae9c9c05/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
index e637e37..7d76ee9 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
@@ -208,6 +208,9 @@ public class QueueListener {
public void stop(){
LOG.info("QueueListener: stop processes");
+ if(futures == null){
+ return;
+ }
for(Future future : futures){
future.cancel(true);
}