diff options
Diffstat (limited to 'qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockQueueEntry.java')
-rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockQueueEntry.java | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockQueueEntry.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockQueueEntry.java index d1a43bc5b6..3f74cb973b 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockQueueEntry.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockQueueEntry.java @@ -23,6 +23,7 @@ package org.apache.qpid.server.queue; import org.apache.qpid.AMQException; import org.apache.qpid.server.subscription.Subscription; import org.apache.qpid.server.message.AMQMessageHeader; +import org.apache.qpid.server.message.AMQMessage; public class MockQueueEntry implements QueueEntry { @@ -71,7 +72,7 @@ public class MockQueueEntry implements QueueEntry public void routeToAlternate() { - + } public void dispose() @@ -124,35 +125,35 @@ public class MockQueueEntry implements QueueEntry return false; } - + public boolean isQueueDeleted() { return false; } - + public boolean isRejectedBy(Subscription subscription) { return false; } - + public void reject() { } - + public void reject(Subscription subscription) { } - + public void release() { @@ -171,7 +172,7 @@ public class MockQueueEntry implements QueueEntry return false; } - + public void requeue() { @@ -190,8 +191,8 @@ public class MockQueueEntry implements QueueEntry } - - public void setRedelivered(boolean b) + + public void setRedelivered() { @@ -209,7 +210,7 @@ public class MockQueueEntry implements QueueEntry public boolean isRedelivered() { - return false; + return false; } |