@@ -16,4 +16,4 @@ |
||
16 | 16 | $admin->declareExchange($exchangeName); |
17 | 17 | $admin->declareAndBindQueue($exchangeName, $queueName); |
18 | 18 | |
19 | -echo 'Added queue "'.$queueName.'" to exchange'."\n"; |
|
19 | +echo 'Added queue "' . $queueName . '" to exchange' . "\n"; |
@@ -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 | } |
@@ -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 | } |
@@ -15,10 +15,10 @@ |
||
15 | 15 | require_once __DIR__ . '/../vendor/autoload.php'; |
16 | 16 | |
17 | 17 | $driver = DriverFactory::getDriver([ |
18 | - 'host' => 'default', |
|
19 | - 'port' => '5672', |
|
20 | - 'user' => 'guest', |
|
21 | - 'pwd' => 'guest' |
|
18 | + 'host' => 'default', |
|
19 | + 'port' => '5672', |
|
20 | + 'user' => 'guest', |
|
21 | + 'pwd' => 'guest' |
|
22 | 22 | ]); |
23 | 23 | $publisher = new SyncPublisher($driver, 'xchange'); |
24 | 24 |
@@ -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 | } |