From 03b99960e0e279a6a6ae6083732c1d43454cd377 Mon Sep 17 00:00:00 2001
From: Marius Bogoevici <marius.bogoevici@yahoo.ca>
Date: Mon, 23 Feb 2009 15:40:42 +0000
Subject: [PATCH] Using MessageSequenceComparator directly.

---
 .../integration/aggregator/Resequencer.java                | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java
index 0359b05972..163406720f 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java
@@ -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;
 	}