- /**
- * Connector visitor method for active tasks
- *
- * @param $connectorInstance A Connectable instance
- * @return void
- */
- public function visitQueryConnector (Connectable $connectorInstance) {
- // Process all pending queries
- $connectorInstance->handlePending();
- }
-
- /**
- * Connector visitor method for active tasks
- *
- * @param $connectorInstance A Connectable instance
- * @return void
- */
- public function visitQueueConnector (Connectable $connectorInstance) {
- // Process all pending queries
- $connectorInstance->handlePending();
- }
-