[hornetq-commits] JBoss hornetq SVN: r11410 - branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/v10.
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();