Repository: usergrid Updated Branches: refs/heads/master 9b12299cc -> 432a8f85e
Fix issue with updated LocalQueueManager creation. Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/432a8f85 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/432a8f85 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/432a8f85 Branch: refs/heads/master Commit: 432a8f85e58ed3817e8c8dae74cdeeb099e04f92 Parents: 9b12299 Author: Michael Russo <mru...@apigee.com> Authored: Fri Nov 18 23:43:52 2016 -0800 Committer: Michael Russo <mru...@apigee.com> Committed: Fri Nov 18 23:43:52 2016 -0800 ---------------------------------------------------------------------- .../usergrid/persistence/queue/impl/QueueManagerFactoryImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/432a8f85/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QueueManagerFactoryImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QueueManagerFactoryImpl.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QueueManagerFactoryImpl.java index 4a41dda..19650c3 100644 --- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QueueManagerFactoryImpl.java +++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QueueManagerFactoryImpl.java @@ -55,7 +55,7 @@ public class QueueManagerFactoryImpl implements LegacyQueueManagerFactory { LegacyQueueManager manager = defaultManager.get( scope.getName() ); if ( manager == null ) { logger.info("Using LocalQueueManager for scope {}", scope.getName() ); - manager = new LocalQueueManager(); + manager = new LocalQueueManager(scope); defaultManager.put( scope.getName(), manager ); } return manager;
