return $this->nodeId;
}
+ /**
+ * Setter for query instance
+ *
+ * @param $queryInstance Our new query instance
+ * @return void
+ */
+ private final function setQueryInstance (Queryable $queryInstance) {
+ $this->queryInstance = $queryInstance;
+ }
+
+ /**
+ * Getter for query instance
+ *
+ * @return $queryInstance Our new query instance
+ */
+ protected final function getQueryInstance () {
+ return $this->queryInstance;
+ }
+
/**
* Checks wether the given IP address matches one of the bootstrapping nodes
*
* @return void
*/
protected function initGenericQueues () {
- // Set it
- $this->queryInstance = ObjectFactory::createObjectByConfiguredName('query_connector_class', array($this));
+ // Set the query connector instance
+ $this->setQueryInstance(ObjectFactory::createObjectByConfiguredName('query_connector_class', array($this)));
+
+ // Run a test query
+ $this->getQueryInstance()->doTestQuery();
}
/**