usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From snoopd...@apache.org
Subject [30/33] git commit: change to managementappid
Date Fri, 05 Sep 2014 21:11:33 GMT
change to managementappid


Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/84d0d500
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/84d0d500
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/84d0d500

Branch: refs/heads/two-dot-o
Commit: 84d0d50082a99a5809acc3fda38d0dc95caa7cd4
Parents: 0a13340
Author: Shawn Feldman <sfeldman@apache.org>
Authored: Thu Sep 4 11:33:46 2014 -0600
Committer: Shawn Feldman <sfeldman@apache.org>
Committed: Thu Sep 4 11:33:46 2014 -0600

----------------------------------------------------------------------
 .../org/apache/usergrid/services/notifications/QueueListener.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/84d0d500/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 0ff8482..29e62c2 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
@@ -112,7 +112,7 @@ public class QueueListener  {
     }
 
     private void execute(){
-        svcMgr = smf.getServiceManager(new UUID( 0, 1 ));
+        svcMgr = smf.getServiceManager(smf.getManagementAppId());
         queueManager = svcMgr.getQueueManager();
         final AtomicInteger consecutiveExceptions = new AtomicInteger();
         // run until there are no more active jobs


Mime
View raw message