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

INT-678 The publish-subscribe-channel's dispatcher now sets the correlation id for outbound messages when its 'apply-sequence' flag is set to true.

Browse Source
This commit is contained in:
Mark Fisher
2009-06-24 16:08:37 +00:00
parent c29af1f5c0
commit cb94548996
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
org.springframework.integration/src/test/java/org/springframework/integration/dispatcher/BroadcastingDispatcherTests.java
View File

@@ -255,14 +255,19 @@ public class BroadcastingDispatcherTests {
dispatcher.addHandler(target1);
dispatcher.addHandler(target2);
dispatcher.addHandler(target3);
dispatcher.dispatch(new StringMessage("test"));
Message<?> inputMessage = new StringMessage("test");
Object originalId = inputMessage.getHeaders().getId();
dispatcher.dispatch(inputMessage);
assertEquals(3, messages.size());
assertEquals(1, (int) messages.get(0).getHeaders().getSequenceNumber());
assertEquals(3, (int) messages.get(0).getHeaders().getSequenceSize());
assertEquals(originalId, messages.get(0).getHeaders().getCorrelationId());
assertEquals(2, (int) messages.get(1).getHeaders().getSequenceNumber());
assertEquals(3, (int) messages.get(1).getHeaders().getSequenceSize());
assertEquals(originalId, messages.get(1).getHeaders().getCorrelationId());
assertEquals(3, (int) messages.get(2).getHeaders().getSequenceNumber());
assertEquals(3, (int) messages.get(2).getHeaders().getSequenceSize());
assertEquals(originalId, messages.get(2).getHeaders().getCorrelationId());
}