Fix RabbitUtils for actual reason when cannot declare exchange

(cherry picked from commit 949bf52)
spring-projects · Oct 3, 2024 · 60f30b9 · 60f30b9
1 parent c325159
commit 60f30b9
Showing 1 changed file with 2 additions and 2 deletions.
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
@@ -354,8 +354,8 @@ public static boolean isExchangeDeclarationFailure(Exception e) {
 		}
 		else {
 			Method shutdownReason = sig.getReason();
-			return shutdownReason instanceof AMQP.Connection.Close closeReason
-					&& AMQP.COMMAND_INVALID == closeReason.getReplyCode()
+			return shutdownReason instanceof AMQP.Channel.Close closeReason
+					&& AMQP.PRECONDITION_FAILED == closeReason.getReplyCode()
 					&& closeReason.getClassId() == EXCHANGE_CLASS_ID_40
 					&& closeReason.getMethodId() == DECLARE_METHOD_ID_10;
 		}