Skip to content

Commit

Permalink
Renamed to be more concise
Browse files Browse the repository at this point in the history
  • Loading branch information
loevgaard committed Sep 11, 2019
1 parent ada3706 commit 2328626
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/Processor/FeedProcessor.php
Original file line number Diff line number Diff line change
Expand Up @@ -20,12 +20,12 @@ final class FeedProcessor implements FeedProcessorInterface
private $feedRepository;

/** @var MessageBusInterface */
private $messageBus;
private $commandBus;

public function __construct(FeedRepositoryInterface $feedRepository, MessageBusInterface $messageBus)
public function __construct(FeedRepositoryInterface $feedRepository, MessageBusInterface $commandBus)
{
$this->feedRepository = $feedRepository;
$this->messageBus = $messageBus;
$this->commandBus = $commandBus;
$this->logger = new NullLogger();
}

Expand All @@ -38,7 +38,7 @@ public function process(): void

foreach ($feeds as $feed) {
$this->logger->info(sprintf('Triggering processing for feed "%s" (id: %s)', $feed->getName(), $feed->getId()));
$this->messageBus->dispatch(new ProcessFeed($feed->getId()));
$this->commandBus->dispatch(new ProcessFeed($feed->getId()));
}
}
}

0 comments on commit 2328626

Please sign in to comment.