diff options
Diffstat (limited to 'qpid/java/systests/src/main/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java index de092fc893..73923b5a06 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java @@ -156,7 +156,7 @@ public class MessageRequeueTest extends QpidBrokerTestCase assertEquals("number of consumed messages does not match initial data", (int) numTestMessages, messagesReceived); // wit 0_10 we can have a delivery tag of 0 - if (conn.isBroker08()) + if (conn.isBroker08() || conn.isBroker09()) { for (long b : messageLog) { @@ -224,7 +224,7 @@ public class MessageRequeueTest extends QpidBrokerTestCase StringBuilder list = new StringBuilder(); list.append("Failed to receive:"); int failed = 0; - if (conn.isBroker08()) + if (conn.isBroker08() || conn.isBroker09()) { for (long b : receieved) { |