diff options
Diffstat (limited to 'java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java')
-rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java b/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java index 98f78e3d69..bf0a8a6d90 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java @@ -48,6 +48,7 @@ import org.apache.mina.common.ByteBuffer; import javax.management.JMException; import java.util.LinkedList; +import java.util.Collections; /** * Test class to test AMQQueueMBean attribtues and operations @@ -216,7 +217,7 @@ public class AMQQueueMBeanTest extends TestCase long id = msg.getMessageId(); _queue.clearQueue(_storeContext); - msg.enqueue(_queue); + msg.enqueue(Collections.singleton(_queue)); msg.routingComplete(_messageStore, new MessageHandleFactory()); msg.addContentBodyFrame(new ContentChunk() @@ -318,7 +319,7 @@ public class AMQQueueMBeanTest extends TestCase for (int i = 0; i < messageCount; i++) { IncomingMessage currentMessage = message(false, persistent); - currentMessage.enqueue(_queue); + currentMessage.enqueue(Collections.singleton(_queue)); // route header currentMessage.routingComplete(_messageStore, new MessageHandleFactory()); |