diff --git a/Persister/QueuePagerPersister.php b/Persister/QueuePagerPersister.php index f45cb92..244ce90 100644 --- a/Persister/QueuePagerPersister.php +++ b/Persister/QueuePagerPersister.php @@ -58,7 +58,7 @@ public function insert(PagerInterface $pager, array $options = array()) $objectPersister = $this->registry->getPersister($options['indexName'], $options['typeName']); $event = new PrePersistEvent($pager, $objectPersister, $options); - $this->dispatcher->dispatch(Events::PRE_PERSIST, $event); + $this->dispatcher->dispatch($event, Events::PRE_PERSIST); $pager = $event->getPager(); $options = $event->getOptions(); @@ -122,7 +122,7 @@ public function insert(PagerInterface $pager, array $options = array()) $errorMessage, $data['options'] ); - $this->dispatcher->dispatch(Events::POST_ASYNC_INSERT_OBJECTS, $event); + $this->dispatcher->dispatch($event, Events::POST_ASYNC_INSERT_OBJECTS); } if (microtime(true) > $limitTime) { @@ -131,6 +131,6 @@ public function insert(PagerInterface $pager, array $options = array()) } $event = new PostPersistEvent($pager, $objectPersister, $options); - $this->dispatcher->dispatch(Events::POST_PERSIST, $event); + $this->dispatcher->dispatch($event, Events::POST_PERSIST); } } diff --git a/composer.json b/composer.json index 2a20d70..42be1ce 100644 --- a/composer.json +++ b/composer.json @@ -6,7 +6,7 @@ "license": "MIT", "require": { "php": "^7.1", - "symfony/framework-bundle": "^3.4|^4.0|^5.0", + "symfony/framework-bundle": "^4.0|^5.0", "friendsofsymfony/elastica-bundle": "^5.0", "enqueue/enqueue-bundle": "^0.10" },