[hornetq-commits] JBoss hornetq SVN: r11410 - branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v10.

[do-not-reply at jboss.org]

Author: gaohoward
Date: 2011-09-25 03:39:38 -0400 (Sun, 25 Sep 2011)
New Revision: 11410

Modified:
   branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v10/StompFrameHandlerV10.java
Log:
remove extra log


Modified: branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v10/StompFrameHandlerV10.java
===================================================================
--- branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v10/StompFrameHandlerV10.java	2011-09-24 20:49:52 UTC (rev 11409)
+++ branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v10/StompFrameHandlerV10.java	2011-09-25 07:39:38 UTC (rev 11410)
@@ -103,12 +103,10 @@
    @Override
    public StompFrame onSend(StompFrame frame)
    {
-      log.error("-------------on Send: " + frame);
       StompFrame response = null;
       try
       {
          connection.validate();
-         log.error("-----------connection is valid");
          String destination = frame.getHeader(Stomp.Headers.Send.DESTINATION);
          String txID = frame.getHeader(Stomp.Headers.TRANSACTION);
 
@@ -120,13 +118,11 @@
          StompUtils.copyStandardHeadersFromFrameToMessage(frame, message);
          if (frame.hasHeader(Stomp.Headers.CONTENT_LENGTH))
          {
-            log.error("--------------------------------it's a bryte type");
             message.setType(Message.BYTES_TYPE);
             message.getBodyBuffer().writeBytes(frame.getBodyAsBytes());
          }
          else
          {
-            log.error("------------------ it's a text type");
             message.setType(Message.TEXT_TYPE);
             String text = frame.getBody();
             message.getBodyBuffer().writeNullableSimpleString(SimpleString.toSimpleString(text));
@@ -336,13 +332,11 @@
       
       if (serverMessage.containsProperty(Stomp.Headers.CONTENT_LENGTH) || serverMessage.getType() == Message.BYTES_TYPE)
       {
-         log.error("------------------- server message is  byte");
          frame.addHeader(Headers.CONTENT_LENGTH, String.valueOf(data.length));
          buffer.readBytes(data);
       }
       else
       {
-         log.error("------------------- server message is  text");
          SimpleString text = buffer.readNullableSimpleString();
          if (text != null)
          {
@@ -377,7 +371,6 @@
    @Override
    public void replySent(StompFrame reply)
    {
-      log.error("-----------------------need destroy? " + reply.needsDisconnect());
       if (reply.needsDisconnect())
       {
          connection.destroy();