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

Fix KinesisMessageHandler.sequenceNumber SpEL

Browse Source
This commit is contained in:
Artem Bilan
2018-02-10 18:57:43 -05:00
parent e88247bb88
commit 8981384b26
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/springframework/integration/aws/outbound/KinesisMessageHandler.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2017 the original author or authors.
* Copyright 2017-2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -167,8 +167,8 @@ public class KinesisMessageHandler extends AbstractAwsMessageHandler {
: null);
String sequenceNumber = message.getHeaders().get(AwsHeaders.SEQUENCE_NUMBER, String.class);
if (!StringUtils.hasText(stream) && this.streamExpression != null) {
partitionKey = this.sequenceNumberExpression.getValue(getEvaluationContext(), message, String.class);
if (!StringUtils.hasText(sequenceNumber) && this.sequenceNumberExpression != null) {
sequenceNumber = this.sequenceNumberExpression.getValue(getEvaluationContext(), message, String.class);
}
Object payload = message.getPayload();