You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2016/10/05 14:04:45 UTC
[4/5] usergrid git commit: Blackout my change,
initializing in constructor causes Guice problems on startup
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 <sn...@apache.org>
Authored: Wed Oct 5 10:00:34 2016 -0400
Committer: Dave Johnson <sn...@apache.org>
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 );
}