33
44use Enqueue \ElasticaBundle \Queue \Commands ;
55use Enqueue \Util \JSON ;
6- use FOS \ElasticaBundle \Persister \Event \Events ;
76use FOS \ElasticaBundle \Persister \Event \PostAsyncInsertObjectsEvent ;
87use FOS \ElasticaBundle \Persister \Event \PostPersistEvent ;
98use FOS \ElasticaBundle \Persister \Event \PrePersistEvent ;
@@ -58,7 +57,7 @@ public function insert(PagerInterface $pager, array $options = array())
5857 $ objectPersister = $ this ->registry ->getPersister ($ options ['indexName ' ], $ options ['typeName ' ]);
5958
6059 $ event = new PrePersistEvent ($ pager , $ objectPersister , $ options );
61- $ this ->dispatcher ->dispatch ($ event, Events:: PRE_PERSIST );
60+ $ this ->dispatcher ->dispatch ($ event );
6261 $ pager = $ event ->getPager ();
6362 $ options = $ event ->getOptions ();
6463
@@ -122,7 +121,7 @@ public function insert(PagerInterface $pager, array $options = array())
122121 $ errorMessage ,
123122 $ data ['options ' ]
124123 );
125- $ this ->dispatcher ->dispatch ($ event, Events:: POST_ASYNC_INSERT_OBJECTS );
124+ $ this ->dispatcher ->dispatch ($ event );
126125 }
127126
128127 if (microtime (true ) > $ limitTime ) {
@@ -131,6 +130,6 @@ public function insert(PagerInterface $pager, array $options = array())
131130 }
132131
133132 $ event = new PostPersistEvent ($ pager , $ objectPersister , $ options );
134- $ this ->dispatcher ->dispatch ($ event, Events:: POST_PERSIST );
133+ $ this ->dispatcher ->dispatch ($ event );
135134 }
136135}
0 commit comments