Ensure physical close flag is reset for test

Author: garyrussell

spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/ContainerShutDownTests.java

@@ -31,10 +31,13 @@
 
 import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
 import org.springframework.amqp.rabbit.connection.Connection;
+import org.springframework.amqp.rabbit.connection.RabbitUtils;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.rabbit.junit.BrokerRunning;
 import org.springframework.amqp.utils.test.TestUtils;
 
+import com.rabbitmq.client.AMQP.BasicProperties;
+
 /**
  * @author Gary Russell
  * @since 2.0
@@ -89,7 +92,11 @@ public void testUninterruptibleListener(AbstractMessageListenerContainer contain
 		container.start();
 		assertTrue(startLatch.await(10, TimeUnit.SECONDS));
 		RabbitTemplate template = new RabbitTemplate(cf);
-		template.convertAndSend("test.shutdown", "foo");
+		template.execute(c -> {
+			c.basicPublish("", "test.shutdown", new BasicProperties(), "foo".getBytes());
+			RabbitUtils.setPhysicalCloseRequired(c, false);
+			return null;
+		});
 		assertTrue(latch.await(10, TimeUnit.SECONDS));
 		Connection connection = cf.createConnection();
 		Map<?, ?> channels = TestUtils.getPropertyValue(connection, "target.delegate._channelManager._channelMap", Map.class);