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

Fix Java 6 compatibility

Browse Source 
https://build.spring.io/browse/INT-SI43X-76
This commit is contained in:
Artem Bilan
2016-12-23 09:46:07 -05:00
parent 44b16cbe81
commit efee77be02
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-integration-core/src/main/java/org/springframework/integration/store/SimpleMessageGroup.java
View File

@@ -46,7 +46,7 @@ public class SimpleMessageGroup implements MessageGroup {
private final Collection<Message<?>> messages;
private final Set<Integer> sequences = new HashSet<>();
private final Set<Integer> sequences = new HashSet<Integer>();
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);
}