@@ -19,5 +19,5 @@ |
||
19 | 19 | $publisher = new AsyncPublisher($driver, 'xchange'); |
20 | 20 | |
21 | 21 | for ($i = 0; $i < $argv[1]; ++$i) { |
22 | - $publisher->publish('event #'.$i, '', ['test' => 'testValue']); |
|
22 | + $publisher->publish('event #' . $i, '', ['test' => 'testValue']); |
|
23 | 23 | } |
@@ -19,5 +19,5 @@ |
||
19 | 19 | $publisher = new SyncPublisher($driver, 'xchange'); |
20 | 20 | |
21 | 21 | for ($i = 0; $i < $argv[1]; ++$i) { |
22 | - echo $publisher->publish('event #'.$i, '', ['test' => 'testValue'])."\n"; |
|
22 | + echo $publisher->publish('event #' . $i, '', ['test' => 'testValue']) . "\n"; |
|
23 | 23 | } |
@@ -19,5 +19,5 @@ |
||
19 | 19 | $publisher = new SyncPublisher($driver, 'xchange'); |
20 | 20 | |
21 | 21 | for ($i = 0; $i < $argv[1]; ++$i) { |
22 | - echo $publisher->publish('event #'.$i, '', ['test' => 'testValue'])."\n"; |
|
22 | + echo $publisher->publish('event #' . $i, '', ['test' => 'testValue']) . "\n"; |
|
23 | 23 | } |
@@ -19,5 +19,5 @@ |
||
19 | 19 | $publisher = new AsyncPublisher($driver, 'xchange'); |
20 | 20 | |
21 | 21 | for ($i = 0; $i < $argv[1]; ++$i) { |
22 | - $publisher->publish('event #'.$i, '', ['test' => 'testValue']); |
|
22 | + $publisher->publish('event #' . $i, '', ['test' => 'testValue']); |
|
23 | 23 | } |