Close publisher and consumer in test

Author: acogoluegnes

src/test/java/com/rabbitmq/client/amqp/impl/TopologyRecoveryTest.java

@@ -270,7 +270,7 @@ void autoDeleteExchangeAndExclusiveQueueShouldBeRedeclared(boolean isolateResour
 
       Sync consumeSync = TestUtils.sync();
       Publisher publisher = connection.publisherBuilder().exchange(e).key("foo").build();
-      connection
+      Consumer consumer = connection
           .consumerBuilder()
           .queue(q)
           .messageHandler(
@@ -291,6 +291,8 @@ void autoDeleteExchangeAndExclusiveQueueShouldBeRedeclared(boolean isolateResour
 
       publisher.publish(publisher.message(), context -> {});
       assertThat(consumeSync).completes();
+      publisher.close();
+      consumer.close();
     }
   }