Emiliano Balbuena · @edgebal · 7d856c7e · Emiliano Balbuena · Emiliano Balbuena
--- a/Core/Provisioner/Provisioners/cassandra-provision.cql
+++ b/Core/Provisioner/Provisioners/cassandra-provision.cql
 hidden_since timestamp, 
 PRIMARY KEY (hashtag) 
 ); 
+ 
+CREATE TABLE minds.search_dispatcher_queue ( 
+ entity_urn text, 
+ last_retry timestamp, 
--- a/Core/Search/Delegates/DispatchIndexDelegate.php
+++ b/Core/Search/Delegates/DispatchIndexDelegate.php
+ 
+ /** 
+ * DispatchIndexDelegate constructor. 
+ * @param EventsDispatcher $eventsDispatcher 
+ * @param SearchIndex $searchIndex 
+ * @param RetryQueueRepository $retryQueue 
+ */ 
+ public function __construct( 
+ $eventsDispatcher = null, 
+ $searchIndex = null, 
+ $retryQueue = null 
+ ) 
+ { 
+ $this->eventsDispatcher = $eventsDispatcher ?: Di::_()->get('EventsDispatcher'); 
+ $this->searchIndex = $searchIndex ?: Di::_()->get('Search\Index'); 
+ $this->retryQueueRepository = $retryQueue ?: new RetryQueueRepository(); 
--- a/Core/Search/Events.php
+++ b/Core/Search/Events.php
 
 class Events 
 { 
+ /** @var Delegates\DispatchIndexDelegate */ 
+ protected $dispatchIndexDelegate; 
+ 
+ /** 
+ * Events constructor. 
+ * @param Delegates\DispatchIndexDelegate $dispatchIndexDelegate 
+ */ 
+ public function __construct( 
+ $dispatchIndexDelegate = null 
+ ) 
+ { 
+ $this->dispatchIndexDelegate = $dispatchIndexDelegate ?: new Delegates\DispatchIndexDelegate();