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;