Factored out asyncShutdown() from processAsync().

Author: Steve Powell

src/com/rabbitmq/client/impl/ChannelN.java

@@ -249,16 +249,7 @@ public void releaseChannelNumber() {
             // We're in normal running mode.
 
             if (method instanceof Channel.Close) {
-                releaseChannelNumber();
-                ShutdownSignalException signal = new ShutdownSignalException(false,
-                                                                             false,
-                                                                             command,
-                                                                             this);
-                synchronized (_channelMutex) {
-                    processShutdownSignal(signal, true, true);
-                    quiescingTransmit(new Channel.CloseOk());
-                }
-                notifyListeners();
+                asyncShutdown(command);
                 return true;
             } else if (method instanceof Basic.Deliver) {
                 Basic.Deliver m = (Basic.Deliver) method;
@@ -357,16 +348,7 @@ public void releaseChannelNumber() {
 
             if (method instanceof Channel.Close) {
                 // We are already shutting down, but we cannot assume no Rpc is waiting.
-                releaseChannelNumber();
-                ShutdownSignalException signal = new ShutdownSignalException(false,
-                                                                             false,
-                                                                             command,
-                                                                             this);
-                synchronized (_channelMutex) {
-                    processShutdownSignal(signal, true, true);
-                    quiescingTransmit(new Channel.CloseOk());
-                }
-                notifyListeners();
+                asyncShutdown(command);
                 return true;
             } else if (method instanceof Channel.CloseOk) {
                 // We're quiescing, and we see a channel.close-ok:
@@ -383,6 +365,19 @@ public void releaseChannelNumber() {
         }
     }
 
+    private void asyncShutdown(Command command) throws IOException {
+        releaseChannelNumber();
+        ShutdownSignalException signal = new ShutdownSignalException(false,
+                                                                     false,
+                                                                     command,
+                                                                     this);
+        synchronized (_channelMutex) {
+            processShutdownSignal(signal, true, true);
+            quiescingTransmit(new Channel.CloseOk());
+        }
+        notifyListeners();
+    }
+
     /** Public API - {@inheritDoc} */
     public void close()
         throws IOException