diff options
| -rw-r--r-- | java/broker/test/src/org/apache/qpid/server/queue/AckTest.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/java/broker/test/src/org/apache/qpid/server/queue/AckTest.java b/java/broker/test/src/org/apache/qpid/server/queue/AckTest.java index 4495ac555b..475aa15d82 100644 --- a/java/broker/test/src/org/apache/qpid/server/queue/AckTest.java +++ b/java/broker/test/src/org/apache/qpid/server/queue/AckTest.java @@ -248,7 +248,7 @@ public class AckTest // which have not bee received so will be queued up in the channel // which should be suspended assertTrue(_subscription.isSuspended()); - Map<Long, AMQChannel.UnacknowledgedMessage> map = _channel.getUnacknowledgedMessageMap(); + Map<Long, UnacknowledgedMessage> map = _channel.getUnacknowledgedMessageMap(); assertTrue(map.size() == highMark); //acknowledge messages so we are just above lowMark |