Loading src/ConnectionFactory.php +1 −1 Original line number Diff line number Diff line Loading @@ -22,7 +22,7 @@ class ConnectionFactory { /** * The RabbitMQ connection. * * @var \PhpAmqpLib\Connection\AMQPStreamConnection * @var \PhpAmqpLib\Connection\AMQPStreamConnection|null */ protected $connection; Loading src/Consumer.php +1 −1 Original line number Diff line number Diff line Loading @@ -65,7 +65,7 @@ class Consumer { * * This is needed to support non-Drush use scenarios. * * @var callable * @var callable|null */ protected $optionGetter; Loading src/Queue/QueueBase.php +1 −1 Original line number Diff line number Diff line Loading @@ -26,7 +26,7 @@ abstract class QueueBase { /** * Object that holds a channel to RabbitMQ. * * @var \PhpAmqpLib\Channel\AMQPChannel * @var \PhpAmqpLib\Channel\AMQPChannel|null */ protected $channel; Loading tests/src/Kernel/RabbitMqQueueBaseTest.php +1 −1 Original line number Diff line number Diff line Loading @@ -14,7 +14,7 @@ class RabbitMqQueueBaseTest extends RabbitMqTestBase { /** * The default queue, handled by RabbitMq. * * @var \Drupal\rabbitmq\Queue\Queue * @var \Drupal\Core\Queue\QueueInterface */ protected $queue; Loading Loading
src/ConnectionFactory.php +1 −1 Original line number Diff line number Diff line Loading @@ -22,7 +22,7 @@ class ConnectionFactory { /** * The RabbitMQ connection. * * @var \PhpAmqpLib\Connection\AMQPStreamConnection * @var \PhpAmqpLib\Connection\AMQPStreamConnection|null */ protected $connection; Loading
src/Consumer.php +1 −1 Original line number Diff line number Diff line Loading @@ -65,7 +65,7 @@ class Consumer { * * This is needed to support non-Drush use scenarios. * * @var callable * @var callable|null */ protected $optionGetter; Loading
src/Queue/QueueBase.php +1 −1 Original line number Diff line number Diff line Loading @@ -26,7 +26,7 @@ abstract class QueueBase { /** * Object that holds a channel to RabbitMQ. * * @var \PhpAmqpLib\Channel\AMQPChannel * @var \PhpAmqpLib\Channel\AMQPChannel|null */ protected $channel; Loading
tests/src/Kernel/RabbitMqQueueBaseTest.php +1 −1 Original line number Diff line number Diff line Loading @@ -14,7 +14,7 @@ class RabbitMqQueueBaseTest extends RabbitMqTestBase { /** * The default queue, handled by RabbitMq. * * @var \Drupal\rabbitmq\Queue\Queue * @var \Drupal\Core\Queue\QueueInterface */ protected $queue; Loading