code: @Override
  	public void addInputChannel(RemoteInputChannel listener) throws IOException {
  		checkError();
  
  		inputChannels.putIfAbsent(listener.getInputChannelId(), listener);
  	}
docs: ------------------------------------------------------------------------