Repository: usergrid Updated Branches: refs/heads/master eaf3b5278 -> dcf38be58
Donât attempt to create queue until actor system is started. Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/dcf38be5 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/dcf38be5 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/dcf38be5 Branch: refs/heads/master Commit: dcf38be58409257b64a5abb4f24b207a742d65ce Parents: eaf3b52 Author: Dave Johnson <snoopd...@apache.org> Authored: Sat Nov 19 08:33:01 2016 -0500 Committer: Dave Johnson <snoopd...@apache.org> Committed: Sat Nov 19 08:33:01 2016 -0500 ---------------------------------------------------------------------- .../apache/usergrid/persistence/queue/impl/QakkaQueueManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/dcf38be5/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QakkaQueueManager.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QakkaQueueManager.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QakkaQueueManager.java index 8887584..6fbe3fe 100644 --- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QakkaQueueManager.java +++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QakkaQueueManager.java @@ -60,7 +60,8 @@ public class QakkaQueueManager implements LegacyQueueManager { this.regions = regions; this.queueNames = new HashSet<>(); - createQueueIfNecessary(); + // Can't create queue here, actor system may not yet be started + //createQueueIfNecessary(); }
