Do not use deprecated getChannel method. (#341)

src/Backend/AMQPBackend.php

@@ -209,7 +209,11 @@ public function getIterator()
         $this->consumer = $this->getContext()->createConsumer($this->getContext()->createQueue($this->queue));
         $this->consumer->setConsumerTag('sonata_notification_'.uniqid());
 
-        return new AMQPMessageIterator($this->getChannel(), $this->consumer);
+        if (!$context instanceof \Enqueue\AmqpLib\AmqpContext) {
+            throw new \LogicException('The BC layer works only if enqueue/amqp-lib lib is being used.');
+        }
+
+        return new AMQPMessageIterator($context->getLibChannel(), $this->consumer);
     }
 
     /**

tests/Backend/AMQPBackendTest.php

@@ -12,9 +12,9 @@
 namespace Sonata\NotificationBundle\Tests\Backend;
 
 use Enqueue\AmqpLib\AmqpConnectionFactory;
+use Enqueue\AmqpLib\AmqpConsumer;
+use Enqueue\AmqpLib\AmqpContext;
 use Interop\Amqp\AmqpBind;
-use Interop\Amqp\AmqpConsumer;
-use Interop\Amqp\AmqpContext;
 use Interop\Amqp\AmqpQueue;
 use Interop\Amqp\AmqpTopic;
 use Interop\Amqp\Impl\AmqpBind as ImplAmqpBind;
@@ -259,6 +259,10 @@ public function testGetIteratorWithNoPrefetchCount()
             ->with($this->identicalTo($queue))
             ->willReturn($consumerMock);
 
+        $contextMock->expects($this->once())
+            ->method('getLibChannel')
+            ->willReturn($this->createMock(AMQPChannel::class));
+
         AmqpConnectionFactoryStub::$context = $contextMock;
 
         $iterator = $backend->getIterator();
@@ -290,6 +294,10 @@ public function testGetIteratorWithPrefetchCount()
             ->with($this->identicalTo($queue))
             ->willReturn($consumerMock);
 
+        $contextMock->expects($this->once())
+            ->method('getLibChannel')
+            ->willReturn($this->createMock(AMQPChannel::class));
+
         AmqpConnectionFactoryStub::$context = $contextMock;
 
         $iterator = $backend->getIterator();
@@ -328,15 +336,8 @@ protected function buildBackend($recover = false, $deadLetterExchange = null, $d
 
         $dispatcherMock = $this->getMockBuilder(AMQPBackendDispatcher::class)
             ->setConstructorArgs([$settings, $queues, 'default', [['type' => self::KEY, 'backend' => $backend]]])
-            ->setMethods(['getChannel'])
             ->getMock();
 
-        $dispatcherMock
-            ->expects($this->any())
-            ->method('getChannel')
-            ->willReturn($this->createMock(AMQPChannel::class))
-        ;
-
         $backend->setDispatcher($dispatcherMock);
 
         return $backend;