Fix AtomJMSIT test failures

Resolve: https://www.pivotaltracker.com/story/show/58726512
fcrepo · Oct 24, 2013 · 69ffe69 · 69ffe69
1 parent a561e1f
commit 69ffe69
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/fcrepo-jms/src/test/java/org/fcrepo/integration/jms/observer/AtomJMSIT.java b/fcrepo-jms/src/test/java/org/fcrepo/integration/jms/observer/AtomJMSIT.java
@@ -127,17 +127,19 @@ public void testAtomStream() throws RepositoryException,
     @Test
     public void testAtomStreamNodePath() throws RepositoryException,
         InterruptedException {
+        final int minEntriesSize = 2;
         Session session = repository.login();
         session.getRootNode().addNode("test1/sigma").addMixin(FEDORA_OBJECT);
         session.save();
 
-        waitForEntry(1);
+        waitForEntry(minEntriesSize);
         session.logout();
 
         if (entries.isEmpty())
             fail("Waited a second, got no messages");
 
         String path = null;
+        assertEquals("Entries size not 2", entries.size(), 2);
         for (Entry entry : entries) {
             List<Category> categories = copyOf(entry.getCategories("xsd:string"));
             String p = null;