diff options
| -rw-r--r-- | java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java b/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java index b09d0456a6..9a497d6da2 100644 --- a/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java +++ b/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java @@ -53,7 +53,6 @@ public class QueueBrowserAutoAckTest extends FailoverBaseCase { super.setUp(); - _queue = (Queue) getInitialContext().lookup("queue"); //Create Client _clientConnection = getConnection(); @@ -62,6 +61,8 @@ public class QueueBrowserAutoAckTest extends FailoverBaseCase setupSession(); + _queue = _clientSession.createQueue(getName()); + //Ensure there are no messages on the queue to start with. checkQueueDepth(0); } |