Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-198 Ensure that the sequence size and sequence number are copied.

Browse Source
This commit is contained in:
Marius Bogoevici
2008-04-15 22:26:47 +00:00
parent ffacaabf64
commit 19aad42c9e
2 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-core/src/main/java/org/springframework/integration/message/GenericMessage.java
View File

@@ -109,6 +109,8 @@ public class GenericMessage<T> implements Message<T> {
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());
}

4
spring-integration-core/src/test/java/org/springframework/integration/message/GenericMessageTests.java
View File

@@ -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<String> message = new GenericMessage<String>("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());
}
}