diff options
Diffstat (limited to 'qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java')
| -rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java index 228c99dcbd..01533d6509 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java @@ -130,7 +130,7 @@ public class TxAckTest extends TestCase MessagePublishInfo info = new MessagePublishInfoImpl(); - AMQMessage message = new TestMessage(deliveryTag, i, info, txnContext.getStoreContext()); + AMQMessage message = new TestMessage(deliveryTag, info); ContentHeaderBody header = new ContentHeaderBody(); header.bodySize = MESSAGE_SIZE; @@ -197,11 +197,9 @@ public class TxAckTest extends TestCase } } - private static AMQMessage createMessage(final long messageId, final MessagePublishInfo publishBody) + private static AMQMessage createMessage(MessagePublishInfo publishBody) { - final AMQMessage amqMessage = (new MessageFactory()).createMessage(messageId, - null, - false); + final AMQMessage amqMessage = (MessageFactory.getInstance()).createMessage(null, false); try { // Safe to use null here as we just created a TransientMessage above @@ -228,10 +226,10 @@ public class TxAckTest extends TestCase private final long _tag; private int _count; - TestMessage(long tag, long messageId, MessagePublishInfo publishBody, StoreContext storeContext) + TestMessage(long tag, MessagePublishInfo publishBody) throws AMQException { - super(createMessage(messageId, publishBody)); + super(createMessage( publishBody)); _tag = tag; } |