[hornetq-commits] JBoss hornetq SVN: r10500 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/client/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-04-13 11:30:27 -0400 (Wed, 13 Apr 2011)
New Revision: 10500

Modified:
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java
Log:
I just realized by looking at the code, and I'm doing sync (blocked) calls on failover, what is not supposed to happen. removing the invalid call.

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java	2011-04-13 11:02:48 UTC (rev 10499)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java	2011-04-13 15:30:27 UTC (rev 10500)
@@ -1083,21 +1083,12 @@
       }
 
       // Resetting the metadata after failover
-      try
+      for (Map.Entry<String, String> entries : metadata.entrySet())
       {
-         for (Map.Entry<String, String> entries : metadata.entrySet())
-         {
-            addMetaData(entries.getKey(), entries.getValue());
-         }
+         sendPacketWithoutLock(new SessionAddMetaDataMessage(entries.getKey(), entries.getValue()));
       }
-      catch (HornetQException e)
-      {
+ }
 
-         log.warn("Error on resending metadata: " + metadata, e);
-
-      }
-   }
-
    public void addMetaData(String key, String data) throws HornetQException
    {
       metadata.put(key, data);