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 72b8e93679..23723bbac9 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
@@ -75,7 +75,7 @@ public class Resequencer extends AbstractMessageBarrierHandler<SortedMap<Integer
 	private boolean hasReceivedAllMessages(SortedMap <Integer, Message<?>> messages) {
 		Message<?> firstMessage = messages.get(messages.firstKey());
 		Message<?> lastMessage = messages.get(messages.lastKey());
-		return (lastMessage.getHeaders().getSequenceNumber() == lastMessage.getHeaders().getSequenceSize()
+		return (lastMessage.getHeaders().getSequenceNumber().equals(lastMessage.getHeaders().getSequenceSize())
 				&& (lastMessage.getHeaders().getSequenceNumber() - firstMessage.getHeaders().getSequenceNumber() == messages.size() - 1));
 	}