QPID-1735 : Removed duplicated methods with differing functionality that was causing FtD to fail. Annoyingly the tests work as they used the method with the extra functionality.

    Commit from 0.5-release : r758382



git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758395 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 2 insertions, 12 deletions

diff --git a/java/broker/src/test/java/org/apache/qpid/server/exchange/AbstractHeadersExchangeTestBase.java b/java/broker/src/test/java/org/apache/qpid/server/exchange/AbstractHeadersExchangeTestBase.java
index 4c9de73a0b..22e49a0241 100644
--- a/java/broker/src/test/java/org/apache/qpid/server/exchange/AbstractHeadersExchangeTestBase.java
+++ b/java/broker/src/test/java/org/apache/qpid/server/exchange/AbstractHeadersExchangeTestBase.java
@@ -280,11 +280,6 @@ public class AbstractHeadersExchangeTestBase extends TestCase
                     //To change body of implemented methods use File | Settings | File Templates.
                 }
 
-                public void setDeliveredToConsumer()
-                {
-                    //To change body of implemented methods use File | Settings | File Templates.
-                }
-
                 public void release()
                 {
                     //To change body of implemented methods use File | Settings | File Templates.
diff --git a/java/broker/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTest.java b/java/broker/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTest.java
index 66ba47ec13..75b0d0ab60 100644
--- a/java/broker/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTest.java
+++ b/java/broker/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTest.java
@@ -21,7 +21,6 @@
 package org.apache.qpid.server.queue;
 
 import junit.framework.TestCase;
-import org.apache.log4j.Logger;
 import org.apache.qpid.AMQException;
 import org.apache.qpid.framing.BasicContentHeaderProperties;
 import org.apache.qpid.framing.ContentHeaderBody;
@@ -33,7 +32,6 @@ import java.util.concurrent.locks.ReentrantLock;
 
 public class QueueEntryImplTest extends TestCase
 {
-    protected static final Logger _log = Logger.getLogger(QueueEntryImplTest.class);
 
     /** Test the Redelivered state of a QueueEntryImpl */
     public void testRedelivered()
@@ -76,7 +74,7 @@ public class QueueEntryImplTest extends TestCase
 
             assertFalse("Undelivered Message should not say it is delivered.", queueEntry.getDeliveredToConsumer());
 
-            queueEntry.setDeliveredToConsumer();
+            queueEntry.setDeliveredToSubscription();
 
             assertTrue("Delivered Message should say it is delivered.", queueEntry.getDeliveredToConsumer());
 
@@ -111,7 +109,7 @@ public class QueueEntryImplTest extends TestCase
 
             assertFalse("Undelivered Message should not say it is delivered.", queueEntry.getDeliveredToConsumer());
 
-            queueEntry.setDeliveredToConsumer();
+            queueEntry.setDeliveredToSubscription();
 
             assertTrue("Delivered Message should say it is delivered.", queueEntry.getDeliveredToConsumer());
 
@@ -170,9 +168,6 @@ public class QueueEntryImplTest extends TestCase
                 }
 
             }
-            _log.info("m.GetExpiration:" + message.getExpiration());
-            _log.info("qe.GetExpiration:" + ((QueueEntryImpl)queueEntry).getExpiration());
-            _log.info("AfterSleep:" + System.currentTimeMillis());
             assertTrue("After a sleep messages should now be expired.", queueEntry.expired());
 
         }