sigh. Accidentally committed to default

Author: David R. MacIver

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

@@ -428,9 +428,9 @@ private class MainLoop extends Thread {
                                     // for non-zero channels (and any inbound commands on
                                     // channel zero that aren't Connection.CloseOk) must
                                     // be discarded.
-                                    _channelManager
-                                        .getChannel(frame.channel)
-                                        .handleFrame(frame);
+                                    ChannelN channel = _channelManager.getChannel(frame.channel);
+                                    // FIXME: catch NullPointerException and throw more informative one?
+                                    channel.handleFrame(frame);
                                 }
                             }
                         }

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

@@ -62,13 +62,9 @@ public synchronized void setChannelMax(int value) {
      * Public API - Looks up an existing channel associated with this connection.
      * @param channelNumber the number of the required channel
      * @return the relevant channel descriptor
-     * @throws UnknownChannelException if there is no Channel associated with the 
-     *         required channel number.
      */
     public ChannelN getChannel(int channelNumber) {
-        ChannelN result = _channelMap.get(channelNumber);
-        if(result == null) throw new UnknownChannelException(channelNumber);
-        return result;
+        return _channelMap.get(channelNumber);
     }
 
     public void handleSignal(ShutdownSignalException signal) {