Skip to content
This repository was archived by the owner on Nov 10, 2025. It is now read-only.

Commit e5acf0f

Browse files
committed
Upgrade dependencies; fix for compatibility
1 parent 5c27dfa commit e5acf0f

File tree

7 files changed

+29
-24
lines changed

7 files changed

+29
-24
lines changed

build.gradle

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ buildscript {
33
maven { url 'http://repo.spring.io/plugins-release' }
44
}
55
dependencies {
6-
classpath 'io.spring.gradle:dependency-management-plugin:1.0.6.RELEASE'
6+
classpath 'io.spring.gradle:dependency-management-plugin:1.0.7.RELEASE'
77
}
88
}
99

@@ -12,7 +12,7 @@ plugins {
1212
id 'eclipse'
1313
id 'idea'
1414
id 'jacoco'
15-
id 'org.sonarqube' version '2.6.2'
15+
id 'org.sonarqube' version '2.7'
1616
id 'checkstyle'
1717
}
1818
description = 'Spring Integration AWS Support'
@@ -30,13 +30,13 @@ repositories {
3030
}
3131

3232
ext {
33-
assertjVersion = '3.11.1'
33+
assertjVersion = '3.12.0'
3434
dynamodbLockClientVersion = '1.0.0'
35-
jacksonVersion = '2.9.7'
36-
servletApiVersion = '4.0.0'
37-
log4jVersion = '2.11.1'
38-
springCloudAwsVersion = '2.1.0.BUILD-SNAPSHOT'
39-
springIntegrationVersion = '5.1.0.RELEASE'
35+
jacksonVersion = '2.9.8'
36+
servletApiVersion = '4.0.1'
37+
log4jVersion = '2.11.2'
38+
springCloudAwsVersion = '2.1.1.BUILD-SNAPSHOT'
39+
springIntegrationVersion = '5.1.4.BUILD-SNAPSHOT'
4040
kinesisClientVersion = '2.0.5'
4141
kinesisProducerVersion = '0.12.11'
4242

@@ -82,7 +82,7 @@ jacoco {
8282

8383
checkstyle {
8484
configFile = file("${rootDir}/src/checkstyle/checkstyle.xml")
85-
toolVersion = "8.14"
85+
toolVersion = "8.17"
8686
}
8787

8888
dependencies {

src/main/java/org/springframework/integration/aws/inbound/SnsInboundChannelAdapter.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -49,15 +49,16 @@
4949
* The {@link HttpRequestHandlingMessagingGateway} extension for the Amazon WS SNS HTTP(S) endpoints.
5050
* Accepts all {@code x-amz-sns-message-type}s, converts the received Topic JSON message to the
5151
* {@link Map} using {@link MappingJackson2HttpMessageConverter} and send it to the provided
52-
* {@link #requestChannel} as {@link Message} {@code payload}.
52+
* {@link #getRequestChannel()} as {@link Message} {@code payload}.
5353
* <p>
5454
* The mapped url must be configured inside the Amazon Web Service platform as a subscription.
5555
* Before receiving any notification itself this HTTP endpoint must confirm the subscription.
5656
* <p>
5757
* The {@link #handleNotificationStatus} flag (defaults to {@code false}) indicates that
5858
* this endpoint should send the {@code SubscriptionConfirmation/UnsubscribeConfirmation}
59-
* messages to the the provided {@link #requestChannel}. If that, the {@link AwsHeaders#NOTIFICATION_STATUS}
60-
* header is populated with the {@link NotificationStatus} value. In that case it is a responsibility of
59+
* messages to the the provided {@link #getRequestChannel()}.
60+
* If that, the {@link AwsHeaders#NOTIFICATION_STATUS} header is populated
61+
* with the {@link NotificationStatus} value. In that case it is a responsibility of
6162
* the application to {@link NotificationStatus#confirmSubscription()} or not.
6263
* <p>
6364
* By default this endpoint just does {@link NotificationStatus#confirmSubscription()}
@@ -106,7 +107,7 @@ public void setHandleNotificationStatus(boolean handleNotificationStatus) {
106107
}
107108

108109
@Override
109-
protected void onInit() throws Exception {
110+
protected void onInit() {
110111
super.onInit();
111112
if (this.payloadExpression != null) {
112113
this.evaluationContext = createEvaluationContext();

src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2017-2018 the original author or authors.
2+
* Copyright 2019 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.

src/main/java/org/springframework/integration/aws/outbound/AbstractAwsMessageHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2017-2018 the original author or authors.
2+
* Copyright 2017-2019 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -167,7 +167,7 @@ protected EvaluationContext getEvaluationContext() {
167167
}
168168

169169
@Override
170-
protected void onInit() throws Exception {
170+
protected void onInit() {
171171
super.onInit();
172172
this.evaluationContext = ExpressionUtils.createStandardEvaluationContext(getBeanFactory());
173173
}

src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2017-2018 the original author or authors.
2+
* Copyright 2019 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -188,9 +188,13 @@ private Future<?> handleUserRecord(Message<?> message, final PutRecordRequest pu
188188
final AsyncHandler<PutRecordRequest, UserRecordResult> asyncHandler =
189189
obtainAsyncHandler(message, putRecordRequest);
190190
final FutureCallback<UserRecordResult> callback = new FutureCallback<UserRecordResult>() {
191+
191192
@Override
192-
public void onFailure(Throwable t) {
193-
asyncHandler.onError((t instanceof Exception) ? ((Exception) t) : new AwsRequestFailureException(message, putRecordRequest, t));
193+
public void onFailure(Throwable ex) {
194+
asyncHandler
195+
.onError(ex instanceof Exception ?
196+
(Exception) ex :
197+
new AwsRequestFailureException(message, putRecordRequest, ex));
194198
}
195199

196200
@Override

src/main/java/org/springframework/integration/aws/outbound/SnsMessageHandler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2016-2018 the original author or authors.
2+
* Copyright 2016-2019 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -61,7 +61,7 @@
6161
* the SNS Message is built from there and the {@code messageStructure}
6262
* of the {@link PublishRequest} is set to {@code json}.
6363
* For the convenience the package {@code org.springframework.integration.aws.support} is imported
64-
* to the {@link #evaluationContext} to allow bypass it for the {@link SnsBodyBuilder}
64+
* to the {@link #getEvaluationContext()} to allow bypass it for the {@link SnsBodyBuilder}
6565
* from the {@link #bodyExpression} definition. For example:
6666
* <pre class="code">
6767
* {@code
@@ -143,7 +143,7 @@ public void setResourceIdResolver(ResourceIdResolver resourceIdResolver) {
143143
}
144144

145145
@Override
146-
protected void onInit() throws Exception {
146+
protected void onInit() {
147147
super.onInit();
148148
TypeLocator typeLocator = getEvaluationContext().getTypeLocator();
149149
if (typeLocator instanceof StandardTypeLocator) {

src/main/java/org/springframework/integration/aws/outbound/SqsMessageHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2016-2018 the original author or authors.
2+
* Copyright 2016-2019 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -150,7 +150,7 @@ public void setMessageConverter(MessageConverter messageConverter) {
150150
}
151151

152152
@Override
153-
protected void onInit() throws Exception {
153+
protected void onInit() {
154154
super.onInit();
155155

156156
if (this.messageConverter == null) {

0 commit comments

Comments
 (0)