Call notifyListeners() on channels that are shutdown by the channelManager().

Author: Steve Powell

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

@@ -59,7 +59,7 @@ public ChannelManager(ConsumerWorkService workService, int channelMax) {
         }
         _channelMax = channelMax;
         channelNumberAllocator = new IntAllocator(1, channelMax);
-        
+
         this.workService = workService;
     }
 
@@ -86,6 +86,7 @@ public void handleSignal(ShutdownSignalException signal) {
             releaseChannelNumber(channel);
             channel.processShutdownSignal(signal, true, true);
             shutdownSet.add(channel.getShutdownLatch());
+            channel.notifyListeners();
         }
         scheduleShutdownProcessing();
     }