From f07caa7d7cd5db276d73e2b44f9f28d122382a14 Mon Sep 17 00:00:00 2001
From: Mark Pollack <mpollack@vmware.com>
Date: Fri, 27 Mar 2009 03:13:51 +0000
Subject: [PATCH] INT-619 - Compilation error on Sun JDK

---
 .../springframework/integration/aggregator/Resequencer.java | 6 +++---
 1 file changed, 3 insertions(+), 3 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 b231753e2b..d878df218c 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
@@ -90,7 +90,7 @@ public class Resequencer extends AbstractMessageBarrierHandler<SortedSet<Message
 		}
 		int sequenceSize = barrier.getMessages().first().getHeaders().getSequenceSize();
 		int messagesCurrentlyInBarrier = barrier.getMessages().size();
-		int lastReleasedSequenceNumber = barrier.getAttribute(LAST_RELEASED_SEQUENCE_NUMBER);
+		Integer lastReleasedSequenceNumber = barrier.getAttribute(LAST_RELEASED_SEQUENCE_NUMBER);
 		return (lastReleasedSequenceNumber + messagesCurrentlyInBarrier == sequenceSize);
 	}
 
@@ -98,7 +98,7 @@ public class Resequencer extends AbstractMessageBarrierHandler<SortedSet<Message
 		if (this.releasePartialSequences || barrier.isComplete()) {
 			ArrayList<Message<?>> releasedMessages = new ArrayList<Message<?>>();
 			Iterator<Message<?>> it = barrier.getMessages().iterator();
-			int lastReleasedSequenceNumber = barrier.getAttribute(LAST_RELEASED_SEQUENCE_NUMBER);
+			Integer lastReleasedSequenceNumber = barrier.getAttribute(LAST_RELEASED_SEQUENCE_NUMBER);
 			while (it.hasNext()) {
 				Message<?> currentMessage = it.next();
 				if (lastReleasedSequenceNumber == currentMessage.getHeaders().getSequenceNumber() - 1) {
@@ -123,7 +123,7 @@ public class Resequencer extends AbstractMessageBarrierHandler<SortedSet<Message
 		if (!super.canAddMessage(message, barrier)) {
 			return false;
 		}
-		int lastReleasedSequenceNumber = barrier.getAttribute(LAST_RELEASED_SEQUENCE_NUMBER);
+		Integer lastReleasedSequenceNumber = barrier.getAttribute(LAST_RELEASED_SEQUENCE_NUMBER);
 		if (barrier.messages.contains(message)
 				|| lastReleasedSequenceNumber >= message.getHeaders().getSequenceNumber()) {
 			logger.debug("A message with the same sequence number has been already received: " + message);