diff options
Diffstat (limited to 'java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java')
| -rw-r--r-- | java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java b/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java index dae81a875d..bbd6deffd3 100644 --- a/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java +++ b/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java @@ -42,6 +42,7 @@ import org.apache.qpid.server.util.NullApplicationRegistry; import java.util.LinkedList; import java.util.Set; +import java.util.Collections; /** * Tests that acknowledgements are handled correctly. @@ -145,7 +146,7 @@ public class AckTest extends TestCase // we increment the reference here since we are not delivering the messaging to any queues, which is where // the reference is normally incremented. The test is easier to construct if we have direct access to the // subscription - msg.enqueue(_queue); + msg.enqueue(Collections.singleton(_queue)); msg.routingComplete(_messageStore, factory); if(msg.allContentReceived()) { |