fixes disabling listeners in replay stream command

chgst · Feb 18, 2019 · b8b08ea · b8b08ea
1 parent 68100bd
commit b8b08ea
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/spec/Command/ReplayStreamCommandSpec.php b/spec/Command/ReplayStreamCommandSpec.php
@@ -49,6 +49,7 @@ function it_can_replay_all_messages(
         $output->isDecorated()->shouldBeCalled();
         $output->getVerbosity()->shouldBeCalled();
 
+        $eventBus->disableListeners()->shouldBeCalled();
         $eventBus->dispatch(Argument::any())->shouldBeCalled();
 
         $this->execute($input, $output);

diff --git a/src/Command/ReplayStreamCommand.php b/src/Command/ReplayStreamCommand.php
@@ -47,6 +47,7 @@ public function configure()
 
     public function execute(InputInterface $input, OutputInterface $output)
     {
+        $this->eventBus->disableListeners();
         $output->writeln('<fg=green>[chgst]</> Replaying all events in the event stream');
 
         $progressBar = new ProgressBar($output, $this->batchSize);