public void closeChannel ( int channelId ) { if ( log . isTraceEnabled ( ) ) { log . trace ( "closeChannel: {}" , channelId ) ; } Channel chan = channels . remove ( channelId ) ; if ( log . isTraceEnabled ( ) ) { log . trace ( "channel: {} for id: {}" , chan , channelId ) ; if ( chan == null ) { log . trace ( "Channels: {}" , channels ) ; } } /* ReceivedMessageTaskQueue queue = tasksByChannels.remove(channelId); if (queue != null) { if (isConnected()) { // if connected, drain and process the tasks queued-up log.debug("Processing remaining tasks at close for channel: {}", channelId); processTasksQueue(queue); } queue.removeAllTasks(); } else if (log.isTraceEnabled()) { log.trace("No task queue for id: {}", channelId); } */ chan = null ; }
Closes channel .