Close ExecutorServices in test

Author: acogoluegnes

src/main/java/com/rabbitmq/client/impl/WorkPoolFullException.java

@@ -0,0 +1,8 @@
+package com.rabbitmq.client.impl;
+
+/**
+ *
+ */
+public class WorkPoolFullException {
+
+}

src/test/java/com/rabbitmq/client/test/SharedThreadPoolTest.java

@@ -30,23 +30,36 @@
 
 public class SharedThreadPoolTest extends BrokerTestCase {
     @Test public void willShutDownExecutor() throws IOException, TimeoutException {
-        ConnectionFactory cf = TestUtils.connectionFactory();
-        cf.setAutomaticRecoveryEnabled(false);
-        ExecutorService executor = Executors.newFixedThreadPool(8);
-        cf.setSharedExecutor(executor);
+        ExecutorService executor1 = null;
+        ExecutorService executor2 = null;
+        try {
+            ConnectionFactory cf = TestUtils.connectionFactory();
+            cf.setAutomaticRecoveryEnabled(false);
+            executor1 = Executors.newFixedThreadPool(8);
+            cf.setSharedExecutor(executor1);
 
-        AMQConnection conn1 = (AMQConnection)cf.newConnection();
-        assertFalse(conn1.willShutDownConsumerExecutor());
+            AMQConnection conn1 = (AMQConnection)cf.newConnection();
+            assertFalse(conn1.willShutDownConsumerExecutor());
 
-        AMQConnection conn2 = (AMQConnection)cf.newConnection(Executors.newSingleThreadExecutor());
-        assertFalse(conn2.willShutDownConsumerExecutor());
+            executor2 = Executors.newSingleThreadExecutor();
+            AMQConnection conn2 = (AMQConnection)cf.newConnection(executor2);
+            assertFalse(conn2.willShutDownConsumerExecutor());
 
-        AMQConnection conn3 = (AMQConnection)cf.newConnection((ExecutorService)null);
-        assertTrue(conn3.willShutDownConsumerExecutor());
+            AMQConnection conn3 = (AMQConnection)cf.newConnection((ExecutorService)null);
+            assertTrue(conn3.willShutDownConsumerExecutor());
 
-        cf.setSharedExecutor(null);
+            cf.setSharedExecutor(null);
 
-        AMQConnection conn4 = (AMQConnection)cf.newConnection();
-        assertTrue(conn4.willShutDownConsumerExecutor());
+            AMQConnection conn4 = (AMQConnection)cf.newConnection();
+            assertTrue(conn4.willShutDownConsumerExecutor());
+        } finally {
+            if (executor1 != null) {
+                executor1.shutdownNow();
+            }
+            if (executor2 != null) {
+                executor2.shutdownNow();
+            }
+        }
+        
     }
 }