use Doctrine\ORM\EntityManager;
use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;
use PhpAmqpLib\Message\AMQPMessage;
-use Wallabag\ImportBundle\Import\PocketImport;
+use Wallabag\ImportBundle\Import\AbstractImport;
use Wallabag\UserBundle\Repository\UserRepository;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
-class PocketConsumer implements ConsumerInterface
+class EntryConsumer implements ConsumerInterface
{
private $em;
private $userRepository;
- private $pocketImport;
+ private $import;
private $logger;
- public function __construct(EntityManager $em, UserRepository $userRepository, PocketImport $pocketImport, LoggerInterface $logger = null)
+ public function __construct(EntityManager $em, UserRepository $userRepository, AbstractImport $import, LoggerInterface $logger = null)
{
$this->em = $em;
$this->userRepository = $userRepository;
- $this->pocketImport = $pocketImport;
+ $this->import = $import;
$this->logger = $logger ?: new NullLogger();
}
return;
}
- $this->pocketImport->setUser($user);
+ $this->import->setUser($user);
- $entry = $this->pocketImport->parseEntry($storedEntry);
+ $entry = $this->import->parseEntry($storedEntry);
if (null === $entry) {
$this->logger->warning('Unable to parse entry', ['entry' => $storedEntry]);