3
3
4
4
use Enqueue \ElasticaBundle \Queue \Commands ;
5
5
use Enqueue \Util \JSON ;
6
- use FOS \ElasticaBundle \Persister \Event \Events ;
7
6
use FOS \ElasticaBundle \Persister \Event \PostAsyncInsertObjectsEvent ;
8
7
use FOS \ElasticaBundle \Persister \Event \PostPersistEvent ;
9
8
use FOS \ElasticaBundle \Persister \Event \PrePersistEvent ;
@@ -58,7 +57,7 @@ public function insert(PagerInterface $pager, array $options = array())
58
57
$ objectPersister = $ this ->registry ->getPersister ($ options ['indexName ' ], $ options ['typeName ' ]);
59
58
60
59
$ event = new PrePersistEvent ($ pager , $ objectPersister , $ options );
61
- $ this ->dispatcher ->dispatch ($ event, Events:: PRE_PERSIST );
60
+ $ this ->dispatcher ->dispatch ($ event );
62
61
$ pager = $ event ->getPager ();
63
62
$ options = $ event ->getOptions ();
64
63
@@ -122,7 +121,7 @@ public function insert(PagerInterface $pager, array $options = array())
122
121
$ errorMessage ,
123
122
$ data ['options ' ]
124
123
);
125
- $ this ->dispatcher ->dispatch ($ event, Events:: POST_ASYNC_INSERT_OBJECTS );
124
+ $ this ->dispatcher ->dispatch ($ event );
126
125
}
127
126
128
127
if (microtime (true ) > $ limitTime ) {
@@ -131,6 +130,6 @@ public function insert(PagerInterface $pager, array $options = array())
131
130
}
132
131
133
132
$ event = new PostPersistEvent ($ pager , $ objectPersister , $ options );
134
- $ this ->dispatcher ->dispatch ($ event, Events:: POST_PERSIST );
133
+ $ this ->dispatcher ->dispatch ($ event );
135
134
}
136
135
}
0 commit comments