upd amqp basic consume specs.

Author: makasim

src/Amqp/BasicConsumeBreakOnFalseSpec.php

@@ -51,9 +51,9 @@ public function test()
         $fooConsumer = $context->createConsumer($fooQueue);
         $barConsumer = $context->createConsumer($barQueue);
 
-        $context->basicConsumeSubscribe($fooConsumer, $callback);
-        $context->basicConsumeSubscribe($barConsumer, $callback);
-        $context->basicConsume(1000);
+        $context->subscribe($fooConsumer, $callback);
+        $context->subscribe($barConsumer, $callback);
+        $context->consume(1000);
 
         $this->assertEquals(1, $consumedMessages);
     }

src/Amqp/BasicConsumeFromAllSubscribedQueuesSpec.php

@@ -53,9 +53,9 @@ public function test()
             return true;
         };
 
-        $context->basicConsumeSubscribe($fooConsumer, $callback);
-        $context->basicConsumeSubscribe($barConsumer, $callback);
-        $context->basicConsume(1000);
+        $context->subscribe($fooConsumer, $callback);
+        $context->subscribe($barConsumer, $callback);
+        $context->consume(1000);
 
         $this->assertEquals([$expectedFooBody, $expectedBarBody], $actualBodies);
         $this->assertEquals(

src/Amqp/BasicConsumeShouldAddConsumerTagOnSubscribeSpec.php

@@ -34,7 +34,7 @@ public function test()
 
         $consumer = $context->createConsumer($queue);
 
-        $context->basicConsumeSubscribe($consumer, function() {});
+        $context->subscribe($consumer, function() {});
 
         $this->assertNotEmpty($consumer->getConsumerTag());
     }

src/Amqp/BasicConsumeShouldRemoveConsumerTagOnUnsubscribeSpec.php

@@ -34,13 +34,13 @@ public function test()
 
         $consumer = $context->createConsumer($queue);
 
-        $context->basicConsumeSubscribe($consumer, function() {});
-        $context->basicConsume(100);
+        $context->subscribe($consumer, function() {});
+        $context->consume(100);
 
         // guard
         $this->assertNotEmpty($consumer->getConsumerTag());
 
-        $context->basicConsumeUnsubscribe($consumer);
+        $context->unsubscribe($consumer);
 
         $this->assertEmpty($consumer->getConsumerTag());
     }

src/Amqp/BasicConsumeUntilUnsubscribedSpec.php

@@ -48,18 +48,18 @@ public function test()
             return true;
         };
 
-        $context->basicConsumeSubscribe($fooConsumer, $callback);
-        $context->basicConsumeSubscribe($barConsumer, $callback);
-        $context->basicConsume(1000);
+        $context->subscribe($fooConsumer, $callback);
+        $context->subscribe($barConsumer, $callback);
+        $context->consume(1000);
 
         $this->assertEquals(2, $consumedMessages);
 
         $context->createProducer()->send($fooQueue, $context->createMessage());
         $context->createProducer()->send($barQueue, $context->createMessage());
 
         $consumedMessages = 0;
-        $context->basicConsumeUnsubscribe($fooConsumer);
-        $context->basicConsume(1000);
+        $context->unsubscribe($fooConsumer);
+        $context->consume(1000);
 
         $this->assertEquals(1, $consumedMessages);
     }