summaryrefslogtreecommitdiff
path: root/java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java')
-rw-r--r--java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java b/java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java
index d4ea728e95..b9b5634109 100644
--- a/java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java
+++ b/java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java
@@ -88,7 +88,9 @@ public class AckTest extends TestCase
MessageHandleFactory factory = new MessageHandleFactory();
for (int i = 1; i <= count; i++)
{
- BasicPublishBody publishBody = new BasicPublishBody();
+ // AMQP version change: Hardwire the version to 0-8 (major=8, minor=0)
+ // TODO: Establish some way to determine the version for the test.
+ BasicPublishBody publishBody = new BasicPublishBody((byte)8, (byte)0);
publishBody.routingKey = "rk";
publishBody.exchange = "someExchange";
AMQMessage msg = new AMQMessage(_messageStore.getNewMessageId(), publishBody, txnContext);