[hornetq-commits] JBoss hornetq SVN: r11767 - in trunk/hornetq-core/src/main/java/org/hornetq/core: replication/impl and 1 other directory.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-11-25 10:01:04 -0500 (Fri, 25 Nov 2011)
New Revision: 11767

Modified:
   trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v11/StompFrameHandlerV11.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java
Log:
Remove unused imports.

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v11/StompFrameHandlerV11.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v11/StompFrameHandlerV11.java	2011-11-25 15:00:50 UTC (rev 11766)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v11/StompFrameHandlerV11.java	2011-11-25 15:01:04 UTC (rev 11767)
@@ -17,10 +17,7 @@
 import java.util.concurrent.atomic.AtomicLong;
 
 import org.hornetq.api.core.HornetQBuffer;
-import org.hornetq.api.core.Message;
-import org.hornetq.api.core.SimpleString;
 import org.hornetq.core.logging.Logger;
-import org.hornetq.core.message.impl.MessageImpl;
 import org.hornetq.core.protocol.stomp.FrameEventListener;
 import org.hornetq.core.protocol.stomp.HornetQStompException;
 import org.hornetq.core.protocol.stomp.SimpleBytes;
@@ -28,11 +25,7 @@
 import org.hornetq.core.protocol.stomp.StompConnection;
 import org.hornetq.core.protocol.stomp.StompDecoder;
 import org.hornetq.core.protocol.stomp.StompFrame;
-import org.hornetq.core.protocol.stomp.StompSubscription;
-import org.hornetq.core.protocol.stomp.StompUtils;
 import org.hornetq.core.protocol.stomp.VersionedStompFrameHandler;
-import org.hornetq.core.server.ServerMessage;
-import org.hornetq.utils.DataConstants;
 
 /**
  * 
@@ -331,6 +324,7 @@
          lastPingTime.set(System.currentTimeMillis());
       }
 
+      @Override
       public void run()
       {
          lastAccepted.set(System.currentTimeMillis());
@@ -434,6 +428,7 @@
    }
    
    //all frame except CONNECT are decoded here.
+   @Override
    public StompFrame decode(StompDecoder decoder, final HornetQBuffer buffer) throws HornetQStompException
    {
       int readable = buffer.readableBytes();

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java	2011-11-25 15:00:50 UTC (rev 11766)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicatedJournal.java	2011-11-25 15:01:04 UTC (rev 11767)
@@ -27,7 +27,6 @@
 import org.hornetq.core.journal.TransactionFailureCallback;
 import org.hornetq.core.journal.impl.JournalFile;
 import org.hornetq.core.journal.impl.dataformat.ByteArrayEncoding;
-import org.hornetq.core.logging.Logger;
 import org.hornetq.core.persistence.OperationContext;
 import org.hornetq.core.persistence.impl.journal.JournalStorageManager;
 import org.hornetq.core.replication.ReplicationManager;
@@ -42,10 +41,6 @@
 public class ReplicatedJournal implements Journal
 {
 
-   // Constants -----------------------------------------------------
-
-   private static final Logger log = Logger.getLogger(ReplicatedJournal.class);
-
    // Attributes ----------------------------------------------------
 
    private static final boolean trace = false;