diff options
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.java | 4 |
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); |