diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/message/AMQMessageReference.java')
-rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/message/AMQMessageReference.java | 24 |
1 files changed, 2 insertions, 22 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/message/AMQMessageReference.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/message/AMQMessageReference.java index 1b4b9a270c..940caaefe4 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/message/AMQMessageReference.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/message/AMQMessageReference.java @@ -20,13 +20,9 @@ */ package org.apache.qpid.server.message; -import org.apache.qpid.server.queue.AMQMessage; +import org.apache.qpid.server.message.AMQMessage; import org.apache.qpid.server.queue.MessageCleanupException; -import javax.swing.*; -import java.util.List; -import java.util.concurrent.CopyOnWriteArrayList; - public class AMQMessageReference extends MessageReference<AMQMessage> { @@ -43,22 +39,6 @@ public class AMQMessageReference extends MessageReference<AMQMessage> protected void onRelease(AMQMessage message) { - try - { - if(message !=null) - { - message.decrementReference(); - } - else - { - //TODO - System.err.println("Shouldn't happen!!!!"); - } - } - catch (MessageCleanupException e) - { - // TODO - throw new RuntimeException(e); - } + message.decrementReference(); } } |