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

Using MessageSequenceComparator directly.

Browse Source
This commit is contained in:
Marius Bogoevici
2009-02-23 15:40:42 +00:00
parent fca5ae5501
commit 03b99960e0
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java
View File

@@ -17,7 +17,6 @@
package org.springframework.integration.aggregator;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.Iterator;
import java.util.List;
import java.util.SortedSet;
@@ -58,11 +57,7 @@ public class Resequencer extends AbstractMessageBarrierHandler<SortedSet<Message
@Override
protected MessageBarrier<SortedSet<Message<?>>> createMessageBarrier(Object correlationKey) {
MessageBarrier<SortedSet<Message<?>>> messageBarrier
= new MessageBarrier<SortedSet<Message<?>>>(new TreeSet<Message<?>>( new Comparator<Message<?>>() {
public int compare(Message<?> message, Message<?> message1) {
return message.getHeaders().getSequenceNumber().compareTo(message1.getHeaders().getSequenceNumber());
}
}), correlationKey);
= new MessageBarrier<SortedSet<Message<?>>>(new TreeSet<Message<?>>(new MessageSequenceComparator()), correlationKey);
messageBarrier.getMessages().add(createFlagMessage(0));
return messageBarrier;
}