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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-08-13 11:55:27 -0400 (Fri, 13 Aug 2010)
New Revision: 9546

Modified:
   trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java
Log:
https://jira.jboss.org/browse/HORNETQ-481 - Each StompSession should have its own executor from the executorFactory

Modified: trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java
===================================================================
--- trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java	2010-08-13 15:15:31 UTC (rev 9545)
+++ trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java	2010-08-13 15:55:27 UTC (rev 9546)
@@ -454,7 +454,7 @@
       StompSession stompSession = sessions.get(connection.getID());
       if (stompSession == null)
       {
-         stompSession = new StompSession(connection, this, server.getStorageManager().newContext(executor));
+         stompSession = new StompSession(connection, this, server.getStorageManager().newContext(server.getExecutorFactory().getExecutor()));
          String name = UUIDGenerator.getInstance().generateStringUUID();
          ServerSession session = server.createSession(name,
                                                       connection.getLogin(),