Blackout my change, initializing in constructor causes Guice problems on startup
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/bd5835ba Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/bd5835ba Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/bd5835ba Branch: refs/heads/usergrid-1318-queue Commit: bd5835ba5de3e54cb34789ec99b5bca81a26883b Parents: 1f28e2a Author: Dave Johnson <[email protected]> Authored: Wed Oct 5 10:00:34 2016 -0400 Committer: Dave Johnson <[email protected]> Committed: Wed Oct 5 10:00:34 2016 -0400 ---------------------------------------------------------------------- .../persistence/queue/impl/QakkaQueueManager.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/bd5835ba/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 4d81a64..2983340 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,8 +60,6 @@ public class QakkaQueueManager implements LegacyQueueManager { this.queueManager = queueManager; this.queueMessageManager = queueMessageManager; this.regions = regions; - - createQueueIfNecessary(); } @@ -81,6 +79,8 @@ public class QakkaQueueManager implements LegacyQueueManager { @Override public <T extends Serializable> void sendMessage(T body) throws IOException { + createQueueIfNecessary(); + ByteArrayOutputStream bos = new ByteArrayOutputStream(); ObjectOutputStream oos = new ObjectOutputStream(bos); oos.writeObject(body); @@ -107,6 +107,8 @@ public class QakkaQueueManager implements LegacyQueueManager { @Override public List<LegacyQueueMessage> getMessages(int limit, Class klass) { + createQueueIfNecessary(); + List<LegacyQueueMessage> messages = new ArrayList<>(); List<QueueMessage> qakkaMessages = queueMessageManager.getNextMessages( scope.getName(), limit ); @@ -140,6 +142,9 @@ public class QakkaQueueManager implements LegacyQueueManager { @Override public long getQueueDepth() { + + createQueueIfNecessary(); + return queueMessageManager.getQueueDepth( scope.getName() ); } @@ -147,6 +152,8 @@ public class QakkaQueueManager implements LegacyQueueManager { @Override public void commitMessage(LegacyQueueMessage queueMessage) { + createQueueIfNecessary(); + UUID queueMessageId = UUID.fromString( queueMessage.getMessageId() ); queueMessageManager.ackMessage( scope.getName(), queueMessageId ); }
