From efee77be027311d791dfd1dadc5428de704dd451 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Fri, 23 Dec 2016 09:46:07 -0500 Subject: [PATCH] Fix Java 6 compatibility https://build.spring.io/browse/INT-SI43X-76 --- .../integration/store/SimpleMessageGroup.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/spring-integration-core/src/main/java/org/springframework/integration/store/SimpleMessageGroup.java b/spring-integration-core/src/main/java/org/springframework/integration/store/SimpleMessageGroup.java index b3315d8039..104b1ce468 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/store/SimpleMessageGroup.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/store/SimpleMessageGroup.java @@ -46,7 +46,7 @@ public class SimpleMessageGroup implements MessageGroup { private final Collection> messages; - private final Set sequences = new HashSet<>(); + private final Set sequences = new HashSet(); private final long timestamp; @@ -118,7 +118,8 @@ public class SimpleMessageGroup implements MessageGroup { @Override public boolean remove(Message message) { - this.sequences.remove(message.getHeaders().get(IntegrationMessageHeaderAccessor.SEQUENCE_NUMBER)); + this.sequences.remove(message.getHeaders() + .get(IntegrationMessageHeaderAccessor.SEQUENCE_NUMBER, Integer.class)); return this.messages.remove(message); }