On 2nd thought: The framing encoding only allows for 16-bit integers for the channel number

0x6e6562 · 0x6e6562 · commit 25ddd019859f · 2009-08-05T12:55:44.000+01:00
diff --git a/src/com/rabbitmq/client/impl/ChannelManager.java b/src/com/rabbitmq/client/impl/ChannelManager.java
@@ -98,7 +98,8 @@ public synchronized ChannelN createChannel(AMQConnection connection, int channel
 
     public synchronized int allocateChannelNumber(int maxChannels) {
         if (maxChannels == 0) {
-            maxChannels = Integer.MAX_VALUE - 1;
+            // The framing encoding only allows for 16-bit integers for the channel number
+            maxChannels = Short.MAX_VALUE;
         }
         int channelNumber = -1;
         for (int candidate = 1; candidate <= maxChannels; candidate++) {

Original file line number	Diff line number	Diff line change
`@@ -98,7 +98,8 @@ public synchronized ChannelN createChannel(AMQConnection connection, int channel`
`98`	`98`
`99`	`99`	`public synchronized int allocateChannelNumber(int maxChannels) {`
`100`	`100`	`if (maxChannels == 0) {`
`101`		`- maxChannels = Integer.MAX_VALUE - 1;`
	`101`	`+ // The framing encoding only allows for 16-bit integers for the channel number`
	`102`	`+ maxChannels = Short.MAX_VALUE;`
`102`	`103`	`}`
`103`	`104`	`int channelNumber = -1;`
`104`	`105`	`for (int candidate = 1; candidate <= maxChannels; candidate++) {`