@@ -27,6 +27,9 @@ discard block |
||
27 | 27 | $this->changeRoutingKey($routingKey); |
28 | 28 | } |
29 | 29 | |
30 | + /** |
|
31 | + * @param string $routingKey |
|
32 | + */ |
|
30 | 33 | public function changeRoutingKey($routingKey) |
31 | 34 | { |
32 | 35 | $this->setAttribute('routing_key', $routingKey); |
@@ -160,6 +163,9 @@ discard block |
||
160 | 163 | return $this->headers; |
161 | 164 | } |
162 | 165 | |
166 | + /** |
|
167 | + * @param string $attributeName |
|
168 | + */ |
|
163 | 169 | public function setAttribute($attributeName, $value) |
164 | 170 | { |
165 | 171 | if($attributeName !== 'headers') |
@@ -180,6 +186,9 @@ discard block |
||
180 | 186 | return $attributes['headers']; |
181 | 187 | } |
182 | 188 | |
189 | + /** |
|
190 | + * @param string $attributeName |
|
191 | + */ |
|
183 | 192 | public function getAttribute($attributeName) |
184 | 193 | { |
185 | 194 | if(array_key_exists($attributeName, $this->attributes)) |
@@ -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; |