code: public void
  run() {
  	try {
  		Message response = res.send(query);
  		listener.receiveMessage(id, response);
  	}
  	catch (Exception e) {
  		listener.handleException(id, e);
  	}
  }
docs: Performs the query, and executes the callback.