Repository: usergrid Updated Branches: refs/heads/master 14b5fe014 -> 80369b985
See if longer waits fix tests on Jenkins. Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/80369b98 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/80369b98 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/80369b98 Branch: refs/heads/master Commit: 80369b985ced40dbb2bf33b067e05995b729eed1 Parents: 14b5fe0 Author: Dave Johnson <snoopd...@apache.org> Authored: Tue Nov 15 11:42:50 2016 -0800 Committer: Dave Johnson <snoopd...@apache.org> Committed: Tue Nov 15 11:42:50 2016 -0800 ---------------------------------------------------------------------- .../usergrid/persistence/qakka/core/QueueMessageManagerTest.java | 2 +- .../persistence/qakka/distributed/QueueActorServiceTest.java | 2 +- .../persistence/qakka/distributed/actors/QueueReaderTest.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/80369b98/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/core/QueueMessageManagerTest.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/core/QueueMessageManagerTest.java b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/core/QueueMessageManagerTest.java index a61eb10..3caf9e9 100644 --- a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/core/QueueMessageManagerTest.java +++ b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/core/QueueMessageManagerTest.java @@ -358,7 +358,7 @@ public class QueueMessageManagerTest extends AbstractAkkaTest { List<QueueMessage> messages = qmm.getNextMessages( queueName, numMessages/2 ); Assert.assertEquals( numMessages/2, messages.size() ); - Thread.sleep(500); + Thread.sleep(3000); // now half messages should be available and half in flight Assert.assertEquals( numMessages/2, qmm.getQueueDepth( queueName, available ) ); http://git-wip-us.apache.org/repos/asf/usergrid/blob/80369b98/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/QueueActorServiceTest.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/QueueActorServiceTest.java b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/QueueActorServiceTest.java index 166581e..428fbb5 100644 --- a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/QueueActorServiceTest.java +++ b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/QueueActorServiceTest.java @@ -149,7 +149,7 @@ public class QueueActorServiceTest extends AbstractAkkaTest { DatabaseQueueMessage.Type type = DatabaseQueueMessage.Type.DEFAULT; - int maxRetries = 10; + int maxRetries = 30; int retries = 0; long count = 0; while (retries++ < maxRetries) { http://git-wip-us.apache.org/repos/asf/usergrid/blob/80369b98/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/actors/QueueReaderTest.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/actors/QueueReaderTest.java b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/actors/QueueReaderTest.java index 9fb8f29..76c2c66 100644 --- a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/actors/QueueReaderTest.java +++ b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/distributed/actors/QueueReaderTest.java @@ -98,7 +98,7 @@ public class QueueReaderTest extends AbstractTest { QueueRefreshRequest refreshRequest = new QueueRefreshRequest( queueName, false ); // need to wait for refresh to complete - int maxRetries = 10; + int maxRetries = 30; int retries = 0; while ( inMemoryQueue.size( queueName ) < qakkaFig.getQueueInMemorySize() && retries++ < maxRetries ) { queueReaderRef.tell( refreshRequest, null ); // tell sends message, returns immediately
