[amqp] make sure messages were acked.

makasim · makasim · commit 66fc53579a30 · 2017-10-11T18:35:04.000+03:00
diff --git a/src/Amqp/BasicConsumeFromAllSubscribedQueuesSpec.php b/src/Amqp/BasicConsumeFromAllSubscribedQueuesSpec.php
@@ -65,6 +65,9 @@ public function test()
             ],
             $actualQueues
         );
+
+        $this->assertEquals(0, $context->declareQueue($fooQueue));
+        $this->assertEquals(0, $context->declareQueue($barQueue));
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -65,6 +65,9 @@ public function test()`
`65`	`65`	`],`
`66`	`66`	`$actualQueues`
`67`	`67`	`);`
	`68`	`+`
	`69`	`+ $this->assertEquals(0, $context->declareQueue($fooQueue));`
	`70`	`+ $this->assertEquals(0, $context->declareQueue($barQueue));`
`68`	`71`	`}`
`69`	`72`
`70`	`73`	`/**`