Work Around HOP/REST Incompatibility in Test

Author: garyrussell

spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/StatelessRetryOperationsInterceptorFactoryBean.java

@@ -67,6 +67,7 @@ protected MethodInvocationRecoverer<?> createRecoverer() {
 		return this::recover;
 	}
 
+	@SuppressWarnings("unchecked")
 	protected Object recover(Object[] args, Throwable cause) {
 		MessageRecoverer messageRecoverer = getMessageRecoverer();
 		Object arg = args[1];

spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/RabbitRestApiTests.java

@@ -17,8 +17,10 @@
 package org.springframework.amqp.rabbit.core;
 
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
 import static org.awaitility.Awaitility.await;
 
+import java.io.IOException;
 import java.net.MalformedURLException;
 import java.net.URISyntaxException;
 import java.util.Collections;
@@ -29,6 +31,7 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.Test;
 
+import org.springframework.amqp.AmqpException;
 import org.springframework.amqp.core.Binding;
 import org.springframework.amqp.core.BindingBuilder;
 import org.springframework.amqp.core.DirectExchange;
@@ -217,7 +220,12 @@ public void testDeleteExchange() {
 		assertThat(exchangeToAssert.getName()).isEqualTo(testExchange.getName());
 		assertThat(exchangeToAssert.getType()).isEqualTo(testExchange.getType());
 		this.rabbitRestClient.deleteExchange("/", testExchange.getName());
-		assertThat(this.rabbitRestClient.getExchange("/", exchangeName)).isNull();
+		// 6.0.0 REST compatibility
+//		assertThat(this.rabbitRestClient.getExchange("/", exchangeName)).isNull();
+		RabbitTemplate template = new RabbitTemplate(this.connectionFactory);
+		assertThatExceptionOfType(AmqpException.class)
+				.isThrownBy(() -> template.execute(channel -> channel.exchangeDeclarePassive(exchangeName)))
+				.withCauseExactlyInstanceOf(IOException.class);
 	}
 
 }