1 files changed, 6 insertions, 8 deletions
diff --git a/java/broker-core/src/test/java/org/apache/qpid/server/consumer/MockConsumer.java b/java/broker-core/src/test/java/org/apache/qpid/server/consumer/MockConsumer.java
index a9b99503ec..5a12a411cf 100644
--- a/java/broker-core/src/test/java/org/apache/qpid/server/consumer/MockConsumer.java
+++ b/java/broker-core/src/test/java/org/apache/qpid/server/consumer/MockConsumer.java
@@ -21,7 +21,6 @@
 
 package org.apache.qpid.server.consumer;
 
-import org.apache.qpid.AMQException;
 import org.apache.qpid.protocol.AMQConstant;
 import org.apache.qpid.server.filter.FilterManager;
 import org.apache.qpid.server.filter.Filterable;
@@ -153,7 +152,7 @@ public class MockConsumer implements ConsumerTarget
     {
     }
 
-    public void send(MessageInstance entry, boolean batch) throws AMQException
+    public void send(MessageInstance entry, boolean batch)
     {
         if (messages.contains(entry))
         {
@@ -205,7 +204,7 @@ public class MockConsumer implements ConsumerTarget
     }
 
 
-    public void queueEmpty() throws AMQException
+    public void queueEmpty()
     {
     }
 
@@ -243,7 +242,7 @@ public class MockConsumer implements ConsumerTarget
         }
 
         @Override
-        public void close() throws AMQException
+        public void close()
         {
         }
 
@@ -255,7 +254,7 @@ public class MockConsumer implements ConsumerTarget
 
         @Override
         public void checkTransactionStatus(long openWarn, long openClose,
-                long idleWarn, long idleClose) throws AMQException
+                long idleWarn, long idleClose)
         {
         }
 
@@ -340,7 +339,7 @@ public class MockConsumer implements ConsumerTarget
         }
 
         @Override
-        public void close(AMQConstant cause, String message) throws AMQException
+        public void close(AMQConstant cause, String message)
         {
         }
     }
@@ -394,13 +393,12 @@ public class MockConsumer implements ConsumerTarget
 
         @Override
         public void close(AMQConstant cause, String message)
-                throws AMQException
         {
         }
 
         @Override
         public void closeSession(AMQSessionModel session, AMQConstant cause,
-                String message) throws AMQException
+                String message)
         {
         }