namespace Wallabag\ImportBundle\Controller;
use Symfony\Bundle\FrameworkBundle\Controller\Controller;
-use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
+use Symfony\Component\Routing\Annotation\Route;
class ImportController extends Controller
{
+ $this->getTotalMessageInRabbitQueue('firefox')
+ $this->getTotalMessageInRabbitQueue('chrome')
+ $this->getTotalMessageInRabbitQueue('instapaper')
+ + $this->getTotalMessageInRabbitQueue('pinboard')
;
} catch (\Exception $e) {
$rabbitNotInstalled = true;
+ $redis->llen('wallabag.import.firefox')
+ $redis->llen('wallabag.import.chrome')
+ $redis->llen('wallabag.import.instapaper')
+ + $redis->llen('wallabag.import.pinboard')
;
} catch (\Exception $e) {
$redisNotInstalled = true;
private function getTotalMessageInRabbitQueue($importService)
{
$message = $this
- ->get('old_sound_rabbit_mq.import_'.$importService.'_consumer')
+ ->get('old_sound_rabbit_mq.import_' . $importService . '_consumer')
->getChannel()
- ->basic_get('wallabag.import.'.$importService);
+ ->basic_get('wallabag.import.' . $importService);
if (null === $message) {
return 0;