Add missed RabbitUtils.clearPhysicalCloseRequired

spring-projects · Mar 16, 2021 · a043dc4 · a043dc4
1 parent bd7656c
commit a043dc4
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/build.gradle b/build.gradle
@@ -2,7 +2,7 @@ buildscript {
 	ext.kotlinVersion = '1.3.72'
 	repositories {
 		maven { url 'https://plugins.gradle.org/m2' }
-		maven { url 'https://repo.spring.io/plugins-release' }
+		maven { url 'https://repo.spring.io/plugins-release-local' }
 	}
 	dependencies {
 		classpath 'org.asciidoctor:asciidoctorj-pdf:1.5.0-beta.5'

diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/RabbitUtils.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/RabbitUtils.java
@@ -229,12 +229,18 @@ public static void setPhysicalCloseRequired(Channel channel, boolean b) {
 	public static boolean isPhysicalCloseRequired() {
 		Boolean mustClose = physicalCloseRequired.get();
 		if (mustClose == null) {
-			mustClose = Boolean.FALSE;
+			return false;
 		}
 		else {
-			physicalCloseRequired.remove();
+			return mustClose;
 		}
-		return mustClose;
+	}
+
+	/**
+	 * Clear the physicalCloseRequired flag.
+	 */
+	public static void clearPhysicalCloseRequired() {
+		physicalCloseRequired.remove();
 	}
 
 	/**