@@ -143,6 +143,9 @@ |
||
143 | 143 | $this->oneOfTheMessagesIs(ContentType::JSON, self::JSON_ROUTING_KEY); |
144 | 144 | } |
145 | 145 | |
146 | + /** |
|
147 | + * @param string $routingKey |
|
148 | + */ |
|
146 | 149 | private function oneOfTheMessagesIs($contentType, $routingKey) |
147 | 150 | { |
148 | 151 | $found = null; |
@@ -1,6 +1,5 @@ |
||
1 | 1 | <?php |
2 | 2 | |
3 | -use Behat\Behat\Tester\Exception\PendingException; |
|
4 | 3 | use Puzzle\AMQP\Messages\Message; |
5 | 4 | use Puzzle\AMQP\Consumers\Insomniac; |
6 | 5 | use Puzzle\AMQP\Workers\Worker; |