File tree Expand file tree Collapse file tree 1 file changed +10
-9
lines changed
src/com/rabbitmq/client/impl Expand file tree Collapse file tree 1 file changed +10
-9
lines changed Original file line number Diff line number Diff line change 4646
4747public class ChannelManager {
4848 /** Mapping from channel number to AMQChannel instance */
49- private final Map <Integer , ChannelN > _channelMap = Collections .synchronizedMap (new HashMap <Integer , ChannelN >());
49+ private final Map <Integer , ChannelN > _channelMap =
50+ Collections .synchronizedMap (new HashMap <Integer , ChannelN >());
5051 private final IntAllocator channelNumberAllocator ;
5152
5253 /** Maximum channel number available on this connection. */
@@ -56,14 +57,14 @@ public int getChannelMax(){
5657 return _channelMax ;
5758 }
5859
59- public ChannelManager (int channelMax ){
60- if (channelMax == 0 ){
61- // The framing encoding only allows for unsigned 16-bit integers for the channel number
62- channelMax = ( 1 << 16 ) - 1 ;
63- }
64-
65- _channelMax = channelMax ;
66- channelNumberAllocator = new IntAllocator (1 , channelMax );
60+ public ChannelManager (int channelMax ) {
61+ if (channelMax == 0 ) {
62+ // The framing encoding only allows for unsigned 16-bit integers
63+ // for the channel number
64+ channelMax = ( 1 << 16 ) - 1 ;
65+ }
66+ _channelMax = channelMax ;
67+ channelNumberAllocator = new IntAllocator (1 , channelMax );
6768 }
6869
6970
You can’t perform that action at this time.
0 commit comments