Author: clebert.suconic(a)jboss.com Date: 2011-12-21 07:29:50 -0500 (Wed, 21 Dec 2011) New Revision: 11923 Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/TestFlowControlOnIgnoreLargeMessageBodyTest.java Log: https://issues.jboss.org/browse/JBPAPP-7161 - oops - I created a dumb regression here.. fixing it Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java =================================================================== --- branches/Branch_2_2_EAP/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java 2011-12-21 12:16:06 UTC (rev 11922) +++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java 2011-12-21 12:29:50 UTC (rev 11923) @@ -1198,8 +1198,6 @@ cacheBridge.addToCache(bridgeDupBytes, context.getTransaction()); message.removeProperty(MessageImpl.HDR_BRIDGE_DUPLICATE_ID); - - message.decrementRefCount(); } Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java =================================================================== --- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java 2011-12-21 12:16:06 UTC (rev 11922) +++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java 2011-12-21 12:29:50 UTC (rev 11923) @@ -1029,6 +1029,11 @@ ClientMessage msg = consumer.receive(10000); + for (int i = 0 ; i < messageSize; i++) + { + assertEquals(getSamplebyte(i), msg.getBodyBuffer().readByte()); + } + assertNotNull(msg); msg.acknowledge(); Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/TestFlowControlOnIgnoreLargeMessageBodyTest.java =================================================================== --- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/TestFlowControlOnIgnoreLargeMessageBodyTest.java 2011-12-21 12:16:06 UTC (rev 11922) +++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/TestFlowControlOnIgnoreLargeMessageBodyTest.java 2011-12-21 12:29:50 UTC (rev 11923) @@ -392,6 +392,7 @@ } assertFalse(error); + assertNull(errorMessage); } catch (Exception e) {