@@ -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; |