This closes #222

This commit is contained in:
Clebert Suconic 2015-10-29 09:20:08 -04:00
commit 5a53de3d5e
1 changed files with 1 additions and 1 deletions

View File

@ -793,7 +793,7 @@ public class PagingTest extends ActiveMQTestBase {
producer.close();
session.start();
long timeout = System.currentTimeMillis() + 5000;
long timeout = System.currentTimeMillis() + 10000;
// I want the buffer full to make sure there are pending messages on the server's side
while (System.currentTimeMillis() < timeout && cons.getBufferSize() < 1000 && cons2.getBufferSize() < 1000) {