[hornetq-commits] JBoss hornetq SVN: r11474 - in trunk: hornetq-core/src/main/java/org/hornetq/core/persistence/impl/nullpm and 1 other directories.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-10-05 12:43:19 -0400 (Wed, 05 Oct 2011)
New Revision: 11474

Modified:
   trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerImpl.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerInternal.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java
   trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/client/impl/LargeMessageBufferTest.java
Log:
Remove unused methods

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerImpl.java	2011-10-05 16:42:56 UTC (rev 11473)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerImpl.java	2011-10-05 16:43:19 UTC (rev 11474)
@@ -405,11 +405,6 @@
       return closed;
    }
 
-   public void stop() throws HornetQException
-   {
-      stop(true);
-   }
-
    public void stop(final boolean waitForOnMessage) throws HornetQException
    {
       waitForOnMessageToComplete(waitForOnMessage);
@@ -450,12 +445,6 @@
 
    // ClientConsumerInternal implementation
    // --------------------------------------------------------------
-
-   public ClientSessionInternal getSession()
-   {
-      return session;
-   }
-   
    public SessionQueueQueryResponseMessage getQueueInfo()
    {
       return queueInfo;

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerInternal.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerInternal.java	2011-10-05 16:42:56 UTC (rev 11473)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerInternal.java	2011-10-05 16:43:19 UTC (rev 11474)
@@ -60,13 +60,9 @@
 
    void flushAcks() throws HornetQException;
 
-   void stop() throws HornetQException;
-
    void stop(boolean waitForOnMessage) throws HornetQException;
 
    void start();
    
    SessionQueueQueryResponseMessage getQueueInfo();
-   
-   ClientSessionInternal getSession();
 }

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java	2011-10-05 16:42:56 UTC (rev 11473)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java	2011-10-05 16:43:19 UTC (rev 11474)
@@ -73,15 +73,6 @@
       // nothing to be done here.. we don really have a file on this Storage
    }
 
-   /* (non-Javadoc)
-    * @see org.hornetq.core.server.LargeServerMessage#complete()
-    */
-   public void complete() throws Exception
-   {
-      // nothing to be done here.. we don really have a file on this Storage
-
-   }
-
    @Override
    public boolean isLargeMessage()
    {

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java	2011-10-05 16:42:56 UTC (rev 11473)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java	2011-10-05 16:43:19 UTC (rev 11474)
@@ -106,11 +106,6 @@
       }
    };
 
-   public void sync()
-   {
-      // NO OP
-   }
-
    public void addQueueBinding(final Binding queueBinding) throws Exception
    {
    }
@@ -149,10 +144,6 @@
    {
    }
 
-   public void storeMessageReferenceScheduled(final long queueID, final long messageID, final long scheduledDeliveryTime) throws Exception
-   {
-   }
-
    public void storeAcknowledgeTransactional(final long txID, final long queueID, final long messageiD) throws Exception
    {
    }
@@ -161,10 +152,6 @@
    {
    }
 
-   public void deletePageTransactional(final long txID, final long messageID) throws Exception
-   {
-   }
-
    public void storeMessage(final ServerMessage message) throws Exception
    {
    }
@@ -185,10 +172,6 @@
    {
    }
 
-   public void updatePageTransaction(final long txID, final PageTransactionInfo pageTransaction) throws Exception
-   {
-   }
-
    public void updateDeliveryCount(final MessageReference ref) throws Exception
    {
    }
@@ -204,10 +187,6 @@
    {
    }
 
-   public void updateDuplicateID(final SimpleString address, final byte[] duplID, final long recordID) throws Exception
-   {
-   }
-
    public void updateDuplicateIDTransactional(final long txID,
                                               final SimpleString address,
                                               final byte[] duplID,
@@ -326,13 +305,6 @@
    }
 
    /* (non-Javadoc)
-    * @see org.hornetq.core.persistence.StorageManager#completeReplication()
-    */
-   public void completeOperations()
-   {
-   }
-
-   /* (non-Javadoc)
     * @see org.hornetq.core.persistence.StorageManager#pageClosed(org.hornetq.utils.SimpleString, int)
     */
    public void pageClosed(final SimpleString storeName, final int pageNumber)

Modified: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/client/impl/LargeMessageBufferTest.java
===================================================================
--- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/client/impl/LargeMessageBufferTest.java	2011-10-05 16:42:56 UTC (rev 11473)
+++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/client/impl/LargeMessageBufferTest.java	2011-10-05 16:43:19 UTC (rev 11474)
@@ -36,7 +36,6 @@
 import org.hornetq.api.core.client.MessageHandler;
 import org.hornetq.core.client.impl.ClientConsumerInternal;
 import org.hornetq.core.client.impl.ClientMessageInternal;
-import org.hornetq.core.client.impl.ClientSessionInternal;
 import org.hornetq.core.client.impl.LargeMessageControllerImpl;
 import org.hornetq.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage;
 import org.hornetq.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage;
@@ -49,8 +48,6 @@
  * A LargeMessageBufferUnitTest
  *
  * @author <a href="mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
- *
- *
  */
 public class LargeMessageBufferTest extends UnitTestCase
 {
@@ -67,6 +64,7 @@
 
    // Public --------------------------------------------------------
 
+   @Override
    protected void setUp() throws Exception
    {
       super.setUp();
@@ -77,6 +75,7 @@
       tmp.mkdirs();
    }
 
+   @Override
    protected void tearDown() throws Exception
    {
       super.tearDown();
@@ -839,12 +838,6 @@
 
       }
 
-      public void stop() throws HornetQException
-      {
-         // TODO Auto-generated method stub
-
-      }
-
       public void stop(boolean waitForOnMessage) throws HornetQException
       {
          // To change body of implemented methods use File | Settings | File Templates.
@@ -855,16 +848,5 @@
          // TODO Auto-generated method stub
          return null;
       }
-
-      /* (non-Javadoc)
-       * @see org.hornetq.core.client.impl.ClientConsumerInternal#getSession()
-       */
-      public ClientSessionInternal getSession()
-      {
-         // TODO Auto-generated method stub
-         return null;
-      }
-
    }
-
 }