Reset physical close flag on test-worker thread

Author: garyrussell

spring-rabbit/src/test/java/org/springframework/amqp/rabbit/connection/CachingConnectionFactoryTests.java

@@ -1512,6 +1512,7 @@ public void testConsumerChannelPhysicallyClosedWhenNotIsOpenGuts(boolean confirm
 				return null;
 			}).when(mockChannel).close();
 			channel.close();
+			RabbitUtils.setPhysicalCloseRequired(channel, false);
 			con.close(); // should be ignored
 
 			assertTrue(physicalCloseLatch.await(10, TimeUnit.SECONDS));
@@ -1649,6 +1650,7 @@ public void testReturnsNormalCloseDeferredClose() throws Exception {
 		Channel channel = conn.createChannel(false);
 		RabbitUtils.setPhysicalCloseRequired(channel, true);
 		channel.close();
+		RabbitUtils.setPhysicalCloseRequired(channel, false);
 		Thread.sleep(6000);
 	}