summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockQueueEntry.java
diff options
context:
space:
mode:
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.java21
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;
}