Skip to content

Commit de4b8e1

Browse files
committed
Upgrade to SA-2.2.17; fix compatibility
1 parent 09e5a1c commit de4b8e1

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ ext {
9494
rsocketVersion = '1.0.3'
9595
servletApiVersion = '4.0.1'
9696
smackVersion = '4.3.4'
97-
springAmqpVersion = project.hasProperty('springAmqpVersion') ? project.springAmqpVersion : '2.2.16.RELEASE'
97+
springAmqpVersion = project.hasProperty('springAmqpVersion') ? project.springAmqpVersion : '2.2.17.RELEASE'
9898
springDataVersion = project.hasProperty('springDataVersion') ? project.springDataVersion : 'Neumann-SR9'
9999
springSecurityVersion = project.hasProperty('springSecurityVersion') ? project.springSecurityVersion : '5.3.9.RELEASE'
100100
springRetryVersion = '1.2.5.RELEASE'

spring-integration-amqp/src/test/java/org/springframework/integration/amqp/channel/DispatcherHasNoSubscribersTests.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2002-2019 the original author or authors.
2+
* Copyright 2002-2021 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.
@@ -35,6 +35,7 @@
3535
import org.springframework.amqp.core.AmqpTemplate;
3636
import org.springframework.amqp.core.Message;
3737
import org.springframework.amqp.core.MessageListener;
38+
import org.springframework.amqp.core.MessageProperties;
3839
import org.springframework.amqp.rabbit.connection.Connection;
3940
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
4041
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
@@ -80,7 +81,7 @@ public void testPtP() throws Exception {
8081

8182
MessageListener listener = (MessageListener) container.getMessageListener();
8283
try {
83-
listener.onMessage(new Message("Hello world!".getBytes(), null));
84+
listener.onMessage(new Message("Hello world!".getBytes(), new MessageProperties()));
8485
fail("Exception expected");
8586
}
8687
catch (MessageDeliveryException e) {
@@ -107,7 +108,7 @@ public void testPubSub() {
107108

108109
List<String> logList = insertMockLoggerInListener(amqpChannel);
109110
MessageListener listener = (MessageListener) container.getMessageListener();
110-
listener.onMessage(new Message("Hello world!".getBytes(), null));
111+
listener.onMessage(new Message("Hello world!".getBytes(), new MessageProperties()));
111112
verifyLogReceived(logList);
112113
}
113114

0 commit comments

Comments
 (0)