docs: @Override
  	public void open(Configuration parameters) throws Exception {
  		try {
  			synchronized (lock) {
  				createConnection();
  			}
  		}
  		catch (IOException e) {
  			throw new IOException("Cannot connect to socket server at " + hostName + ":" + port, e);
  		}
  	}