[hornetq-commits] JBoss hornetq SVN: r11284 - branches/one-offs/Hornetq_2_2_4_EAP_JBPAPP_7116/src/main/org/hornetq/core/postoffice/impl.

Author: clebert.suconic(a)jboss.com Date: 2011-09-01 19:18:06 -0400 (Thu, 01 Sep 2011) New Revision: 11284 Modified: branches/one-offs/Hornetq_2_2_4_EAP_JBPAPP_7116/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java Log: backporting a fix on cleanup properties (IllegalStateException that could happen on clustering routing) Modified: branches/one-offs/Hornetq_2_2_4_EAP_JBPAPP_7116/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java =================================================================== --- branches/one-offs/Hornetq_2_2_4_EAP_JBPAPP_7116/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java 2011-09-01 23:11:30 UTC (rev 11283) +++ branches/one-offs/Hornetq_2_2_4_EAP_JBPAPP_7116/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java 2011-09-01 23:18:06 UTC (rev 11284) @@ -18,6 +18,7 @@ import java.util.HashMap; import java.util.HashSet; import java.util.Iterator; +import java.util.LinkedList; import java.util.List; import java.util.Map; import java.util.Set; @@ -812,15 +813,30 @@ */ protected void cleanupInternalPropertiesBeforeRouting(final ServerMessage message) { + LinkedList<SimpleString> valuesToRemove = null; + + for (SimpleString name : message.getPropertyNames()) { // We use properties to establish routing context on clustering. // However if the client resends the message after receiving, it needs to be removed if (name.startsWith(MessageImpl.HDR_ROUTE_TO_IDS) && !name.equals(MessageImpl.HDR_ROUTE_TO_IDS)) { - message.removeProperty(name); + if (valuesToRemove == null) + { + valuesToRemove = new LinkedList<SimpleString>(); + } + valuesToRemove.add(name); } } + + if (valuesToRemove != null) + { + for (SimpleString removal : valuesToRemove) + { + message.removeProperty(removal); + } + } }