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

Upgrade Versions; Prepare for Milestone Release

Browse Source
This commit is contained in:
Gary Russell
2022-01-16 10:11:21 -05:00
parent 1a1b1f6c3c
commit 006b018171
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
build.gradle
View File

@@ -55,15 +55,15 @@ ext {
log4jVersion = '2.17.1'
logbackVersion = '1.2.3'
lz4Version = '1.8.0'
micrometerVersion = '1.8.0'
micrometerVersion = '2.0.0-M1'
mockitoVersion = '3.11.2'
rabbitmqStreamVersion = '0.4.0'
rabbitmqVersion = project.hasProperty('rabbitmqVersion') ? project.rabbitmqVersion : '5.13.1'
rabbitmqHttpClientVersion = '3.12.1'
reactorVersion = '2020.0.14'
reactorVersion = '2020.0.15'
snappyVersion = '1.1.8.4'
springDataCommonsVersion = '2.6.0'
springVersion = project.hasProperty('springVersion') ? project.springVersion : '6.0.0-SNAPSHOT'
springDataCommonsVersion = '3.0.0-M1'
springVersion = project.hasProperty('springVersion') ? project.springVersion : '6.0.0-M2'
springRetryVersion = '1.3.1'
zstdJniVersion = '1.5.0-2'
}

2
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/AbstractMessageListenerContainer.java
View File

@@ -2139,6 +2139,7 @@ public abstract class AbstractMessageListenerContainer extends RabbitAccessor
return Timer.start(this.registry);
}
@SuppressWarnings("deprecation")
void success(Object sample, String queue) {
Timer timer = this.timers.get(queue + "none");
if (timer == null) {
@@ -2147,6 +2148,7 @@ public abstract class AbstractMessageListenerContainer extends RabbitAccessor
((Sample) sample).stop(timer);
}
@SuppressWarnings("deprecation")
void failure(Object sample, String queue, String exception) {
Timer timer = this.timers.get(queue + exception);
if (timer == null) {