You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2015/08/14 23:03:00 UTC
incubator-usergrid git commit: test queue depth matches
Repository: incubator-usergrid
Updated Branches:
refs/heads/USERGRID-543 ee6e087f8 -> daac07d2b
test queue depth matches
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/daac07d2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/daac07d2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/daac07d2
Branch: refs/heads/USERGRID-543
Commit: daac07d2b6d5069cb10867ca33daeb3534dd1f6e
Parents: ee6e087
Author: Shawn Feldman <sf...@apache.org>
Authored: Fri Aug 14 15:02:51 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Fri Aug 14 15:02:51 2015 -0600
----------------------------------------------------------------------
.../usergrid/persistence/queue/QueueManagerTest.java | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/daac07d2/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/queue/QueueManagerTest.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/queue/QueueManagerTest.java b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/queue/QueueManagerTest.java
index e948015..f265620 100644
--- a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/queue/QueueManagerTest.java
+++ b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/queue/QueueManagerTest.java
@@ -39,6 +39,7 @@ import org.apache.usergrid.persistence.queue.impl.QueueScopeImpl;
import com.google.inject.Inject;
+import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import static org.junit.Assume.assumeTrue;
@@ -112,15 +113,20 @@ public class QueueManagerTest {
List<Map<String,String>> bodies = new ArrayList<>();
bodies.add(values);
+ long initialDepth = qm.getQueueDepth();
qm.sendMessages(bodies);
long depth = qm.getQueueDepth();
assertTrue(depth>0);
- List<QueueMessage> messageList = qm.getMessages(1,5000,5000,values.getClass()).toList().toBlocking().last();
- assertTrue(messageList.size() >= 1);
+ List<QueueMessage> messageList = qm.getMessages(10,5000,5000,values.getClass()).toList().toBlocking().last();
+ assertTrue(messageList.size() <= 500);
for(QueueMessage message : messageList){
assertTrue(message.getBody().equals(values));
}
- qm.commitMessages(messageList);
+ if(messageList.size()>0) {
+ qm.commitMessages(messageList);
+ }
+ depth = qm.getQueueDepth();
+ assertEquals(initialDepth, depth);
}