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

Author: clebert.suconic(a)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);