public void close ( ) throws IOException , InterruptedException { for ( int i = 0 ; i < this . getNumberOfInputChannels ( ) ; i ++ ) { final InputChannel < T > inputChannel = this . channels [ i ] ; inputChannel . close ( ) ; } }
Immediately closes the input gate and all its input channels . The corresponding output channels are notified . Any remaining records in any buffers or queue is considered irrelevant and is discarded .