[jboss-cvs] JBoss Messaging SVN: r6899 - trunk/src/main/org/jboss/messaging/core/persistence/impl/journal.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-05-19 15:14:07 -0400 (Tue, 19 May 2009)
New Revision: 6899

Modified:
   trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalStorageManager.java
Log:
Tweak: Destination is not used any more

Modified: trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalStorageManager.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalStorageManager.java	2009-05-19 19:08:13 UTC (rev 6898)
+++ trunk/src/main/org/jboss/messaging/core/persistence/impl/journal/JournalStorageManager.java	2009-05-19 19:14:07 UTC (rev 6899)
@@ -35,7 +35,6 @@
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.Executor;
-import java.util.concurrent.Executors;
 import java.util.concurrent.atomic.AtomicLong;
 
 import javax.transaction.xa.Xid;
@@ -1241,36 +1240,6 @@
       }
    }
 
-   private static class DestinationEncoding implements EncodingSupport
-   {
-      SimpleString destination;
-
-      DestinationEncoding(final SimpleString destination)
-      {
-         this.destination = destination;
-      }
-
-      DestinationEncoding()
-      {
-      }
-
-      public void decode(final MessagingBuffer buffer)
-      {
-         destination = buffer.readSimpleString();
-      }
-
-      public void encode(final MessagingBuffer buffer)
-      {
-         buffer.writeSimpleString(destination);
-      }
-
-      public int getEncodeSize()
-      {
-         return SimpleString.sizeofString(destination);
-      }
-
-   }
-
    private static class PersistentIDEncoding implements EncodingSupport
    {
       UUID uuid;
@@ -1582,10 +1551,6 @@
       {
       }
 
-      private void pageMessages(final Transaction tx) throws Exception
-      {
-      }
-
       /* (non-Javadoc)
        * @see org.jboss.messaging.core.transaction.TransactionOperation#getDistinctQueues()
        */