From 19aad42c9e5e5761b3d0f934d43998a433736f31 Mon Sep 17 00:00:00 2001 From: Marius Bogoevici Date: Tue, 15 Apr 2008 22:26:47 +0000 Subject: [PATCH] INT-198 Ensure that the sequence size and sequence number are copied. --- .../springframework/integration/message/GenericMessage.java | 2 ++ .../integration/message/GenericMessageTests.java | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/spring-integration-core/src/main/java/org/springframework/integration/message/GenericMessage.java b/spring-integration-core/src/main/java/org/springframework/integration/message/GenericMessage.java index 81392873e6..5fa1033ca3 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/message/GenericMessage.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/message/GenericMessage.java @@ -109,6 +109,8 @@ public class GenericMessage implements Message { for (String key : attributeNames) { this.header.setAttribute(key, headerToCopy.getAttribute(key)); } + this.header.setSequenceNumber(headerToCopy.getSequenceNumber()); + this.header.setSequenceSize(headerToCopy.getSequenceSize()); this.header.setReturnAddress(headerToCopy.getReturnAddress()); } diff --git a/spring-integration-core/src/test/java/org/springframework/integration/message/GenericMessageTests.java b/spring-integration-core/src/test/java/org/springframework/integration/message/GenericMessageTests.java index 6208b0cfab..da019f6e2c 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/message/GenericMessageTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/message/GenericMessageTests.java @@ -61,9 +61,13 @@ public class GenericMessageTests { MessageHeader header = new MessageHeader(); header.setAttribute("testAttribute", new Integer(123)); header.setProperty("testProperty", "foo"); + header.setSequenceSize(42); + header.setSequenceNumber(24); GenericMessage message = new GenericMessage("test", header); assertEquals(new Integer(123), message.getHeader().getAttribute("testAttribute")); assertEquals("foo", message.getHeader().getProperty("testProperty")); + assertEquals(42, message.getHeader().getSequenceSize()); + assertEquals(24, message.getHeader().getSequenceNumber()); } }