[hornetq-commits] JBoss hornetq SVN: r8899 - trunk/src/main/org/hornetq/core/protocol/stomp.

[do-not-reply at jboss.org]

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)
          {