Author: jmesnil
Date: 2010-02-25 09:47:40 -0500 (Thu, 25 Feb 2010)
New Revision: 8899
Modified:
trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-129: Implement STOMP v1.0
* do *not* flush when sending a frame on the wire
* removed the executor step when handling a buffer
Modified: trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java
===================================================================
--- trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java 2010-02-24
09:36:53 UTC (rev 8898)
+++ trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java 2010-02-25
14:47:40 UTC (rev 8899)
@@ -141,20 +141,14 @@
public void handleBuffer(final RemotingConnection connection, final HornetQBuffer
buffer)
{
- executor.execute(new Runnable()
+ try
{
- public void run()
- {
- try
- {
- doHandleBuffer(connection, buffer);
- }
- finally
- {
- server.getStorageManager().clearContext();
- }
- }
- });
+ doHandleBuffer(connection, buffer);
+ }
+ finally
+ {
+ server.getStorageManager().clearContext();
+ }
}
private void doHandleBuffer(final RemotingConnection connection, final HornetQBuffer
buffer)
@@ -618,7 +612,7 @@
try
{
HornetQBuffer buffer = frame.toHornetQBuffer();
- connection.getTransportConnection().write(buffer, true);
+ connection.getTransportConnection().write(buffer, false);
}
catch (Exception e)
{