code: @Override
  	void sendTaskEvent(TaskEvent event) throws IOException {
  		checkState(!isReleased.get(), "Tried to send task event to producer after channel has been released.");
  		checkState(partitionRequestClient != null, "Tried to send task event to producer before requesting a queue.");
  
  		checkError();
  
  		partitionRequestClient.sendTaskEvent(partitionId, event, this);
  	}
docs: ------------------------------------------------------------------------