| @@ -13,7 +13,7 @@ | ||
| 13 | 13 | * - string $exchange | 
| 14 | 14 | * - string $routingKey | 
| 15 | 15 | */ | 
| 16 | - public function foreach(callable $consume): void; | |
| 16 | + public function foreach (callable $consume): void; | |
| 17 | 17 | |
| 18 | 18 | /** | 
| 19 | 19 | * Number of messages to process | 
| @@ -50,7 +50,7 @@ | ||
| 50 | 50 | /** | 
| 51 | 51 |       * {@inheritdoc} | 
| 52 | 52 | */ | 
| 53 | - public function foreach(callable $consume): void | |
| 53 | + public function foreach (callable $consume): void | |
| 54 | 54 |      { | 
| 55 | 55 |          if ($this->canceled) { | 
| 56 | 56 | return; | 
| @@ -10,7 +10,7 @@ | ||
| 10 | 10 | /** | 
| 11 | 11 |       * {@inheritdoc} | 
| 12 | 12 | */ | 
| 13 | - public function foreach(callable $consume): void | |
| 13 | + public function foreach (callable $consume): void | |
| 14 | 14 |      { | 
| 15 | 15 | //pass | 
| 16 | 16 | } | 
| @@ -28,7 +28,7 @@ | ||
| 28 | 28 | /** | 
| 29 | 29 |       * {@inheritdoc} | 
| 30 | 30 | */ | 
| 31 | - public function foreach(callable $consume): void | |
| 31 | + public function foreach (callable $consume): void | |
| 32 | 32 |      { | 
| 33 | 33 |          $this->consumer->foreach(function(Message $message, ...$args) use ($consume): void { | 
| 34 | 34 |              try { |