You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2014/09/08 19:05:00 UTC

svn commit: r1623432 - /qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/logging/ConsumerLoggingTest.java

Author: rgodfrey
Date: Mon Sep  8 17:05:00 2014
New Revision: 1623432

URL: http://svn.apache.org/r1623432
Log:
QPID-6088 : [Java Client] reenable logging test

Modified:
    qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/logging/ConsumerLoggingTest.java

Modified: qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/logging/ConsumerLoggingTest.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/logging/ConsumerLoggingTest.java?rev=1623432&r1=1623431&r2=1623432&view=diff
==============================================================================
--- qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/logging/ConsumerLoggingTest.java (original)
+++ qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/logging/ConsumerLoggingTest.java Mon Sep  8 17:05:00 2014
@@ -20,12 +20,8 @@
  */
 package org.apache.qpid.server.logging;
 
-import javax.jms.QueueBrowser;
-import junit.framework.AssertionFailedError;
-import org.apache.log4j.Level;
-import org.apache.log4j.Logger;
-
-import org.apache.qpid.client.AMQConnection;
+import java.io.IOException;
+import java.util.List;
 
 import javax.jms.Connection;
 import javax.jms.JMSException;
@@ -34,8 +30,12 @@ import javax.jms.MessageConsumer;
 import javax.jms.Queue;
 import javax.jms.Session;
 import javax.jms.Topic;
-import java.io.IOException;
-import java.util.List;
+
+import junit.framework.AssertionFailedError;
+import org.apache.log4j.Level;
+import org.apache.log4j.Logger;
+
+import org.apache.qpid.client.AMQConnection;
 
 /**
  * Subscription
@@ -366,7 +366,7 @@ public class ConsumerLoggingTest extends
 // INFO - MESSAGE [con:6(guest@anonymous(26562441)/test)/ch:3] [sub:6(qu(example.queue))] SUB-1003 : State :
 // INFO - MESSAGE [sub:6(vh(test)/qu(example.queue))] [sub:6(qu(example.queue))] SUB-1003 : State :
 
-            assertEquals("Result set not expected size:", 3, results.size());
+            assertTrue("Result set not expected size:", 3 <= results.size());
 
             // Validate Initial Suspension
             String expectedState = "SUSPENDED";



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org