Minimise test

Author: Emile Joubert

test/src/com/rabbitmq/client/test/functional/PerMessageTTL.java

@@ -60,10 +60,9 @@ public void testExpiryWhenConsumerIsLateToTheParty() throws Exception {
     }
 
     public void testRestartingExpiry() throws Exception {
-        final String restartDelay = "5000";
+        final String restartDelay = "2000";
         declareDurableQueue(TTL_QUEUE_NAME);
-        bindQueue();
-        channel.basicPublish(TTL_EXCHANGE, TTL_QUEUE_NAME,
+        channel.basicPublish("", TTL_QUEUE_NAME,
                 MessageProperties.MINIMAL_PERSISTENT_BASIC
                         .builder()
                         .expiration(restartDelay)
@@ -75,6 +74,9 @@ public void testRestartingExpiry() throws Exception {
                 public void run() {
                     try {
                         Thread.sleep(Integer.parseInt(restartDelay));
+                        while (channel == null || !channel.isOpen()) {
+                            Thread.sleep(250);
+                        }
                         retrievedMsg = get();
                     } catch (IOException e) {
                     } catch (InterruptedException e) {