fix tests.

Author: makasim

tests/Functional/SendAndReceiveDelayedMessageTest.php

@@ -12,6 +12,9 @@
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
 
+/**
+ * @group functional
+ */
 class SendAndReceiveDelayedMessageTest extends TestCase
 {
     public function test()

tests/Functional/SendAndReceiveMessageTest.php

@@ -12,6 +12,9 @@
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
 
+/**
+ * @group functional
+ */
 class SendAndReceiveMessageTest extends TestCase
 {
     public function test()

tests/Functional/SslConnectionTest.php

@@ -11,6 +11,9 @@
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors\RabbitMQConnector;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
 
+/**
+ * @group functional
+ */
 class SslConnectionTest extends TestCase
 {
     public function testConnectorEstablishSecureConnectionWithRabbitMQBroker()

tests/Functional/StreamConnectionTest.php

@@ -11,6 +11,9 @@
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors\RabbitMQConnector;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
 
+/**
+ * @group functional
+ */
 class StreamConnectionTest extends TestCase
 {
     public function testConnectorEstablishSecureConnectionWithRabbitMQBroker()

tests/Queue/Jobs/RabbitMQJobTest.php

@@ -38,29 +38,36 @@ public function testShouldUseDetectDeadlocksTrait()
 
     public function testCouldBeConstructedWithExpectedArguments()
     {
-        new RabbitMQJob(
+        $queue = $this->createMock(\Interop\Amqp\AmqpQueue::class);
+        $queue
+            ->expects($this->once())
+            ->method('getQueueName')
+            ->willReturn('theQueueName')
+        ;
+
+        $consumerMock = $this->createConsumerMock();
+        $consumerMock
+            ->expects($this->once())
+            ->method('getQueue')
+            ->willReturn($queue)
+        ;
+
+        $job = new RabbitMQJob(
             new Container(),
             $this->createRabbitMQQueueMock(),
-            $this->createConsumerMock(),
+            $consumerMock,
             new AmqpMessage()
         );
+
+        $this->assertAttributeSame('theQueueName', 'queue', $job);
     }
 
     /**
      * @return AmqpConsumer|\PHPUnit_Framework_MockObject_MockObject|AmqpConsumer
      */
-    private function createConsumerMock(string $queueName = 'test')
+    private function createConsumerMock()
     {
-        $mock =  $this->createMock(AmqpConsumer::class);
-
-        if ($queueName !== '')
-        {
-            $mock->expects($this->once())
-                ->method('getQueue')
-                ->willReturn(new AmqpQueue($queueName));
-        }
-
-        return $mock;
+        return $this->createMock(AmqpConsumer::class);
     }
 
     /**

tests/Queue/RabbitMQQueueTest.php

@@ -363,6 +363,11 @@ public function testShouldReturnRabbitMQJobIfMessageReceivedFromQueue()
             ->method('receiveNoWait')
             ->willReturn($message)
         ;
+        $consumer
+            ->expects($this->once())
+            ->method('getQueue')
+            ->willReturn($queue)
+        ;
 
         $context = $this->createAmqpContext();
         $context