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

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@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; - } - } - }