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();