@@ -103,6 +103,9 @@ discard block |
||
| 103 | 103 | $this->theMessageIs(self::JSON_ROUTING_KEY, ContentType::JSON); |
| 104 | 104 | } |
| 105 | 105 | |
| 106 | + /** |
|
| 107 | + * @param string $routingKey |
|
| 108 | + */ |
|
| 106 | 109 | private function theMessageIs($routingKey, $contentType) |
| 107 | 110 | { |
| 108 | 111 | $firstMessage = $this->consumedMessages[0]; |
@@ -145,6 +148,9 @@ discard block |
||
| 145 | 148 | $this->oneOfTheMessagesIs(ContentType::JSON, self::JSON_ROUTING_KEY); |
| 146 | 149 | } |
| 147 | 150 | |
| 151 | + /** |
|
| 152 | + * @param string $routingKey |
|
| 153 | + */ |
|
| 148 | 154 | private function oneOfTheMessagesIs($contentType, $routingKey) |
| 149 | 155 | { |
| 150 | 156 | $found = null; |