Evaneos / Burrow

examples/async-message-sender-amqplib.php

Spacing +1 added lines, -1 removed lines

@@ -19,5 +19,5 @@
 $publisher = new AsyncPublisher($driver, 'xchange');

 

 for ($i = 0; $i < $argv[1]; ++$i) {

-    $publisher->publish('event #'.$i, '', ['test' => 'testValue']);

+    $publisher->publish('event #' . $i, '', ['test' => 'testValue']);

 }

examples/sync-message-sender.php

Indentation +4 added lines, -4 removed lines

@@ -15,10 +15,10 @@
 require_once __DIR__ . '/../vendor/autoload.php';

 

 $driver = DriverFactory::getDriver([

-   'host' => 'default',

-   'port' => '5672',

-   'user' => 'guest',

-   'pwd' => 'guest'

+    'host' => 'default',

+    'port' => '5672',

+    'user' => 'guest',

+    'pwd' => 'guest'

 ]);

 $publisher = new SyncPublisher($driver, 'xchange');

 

Spacing +1 added lines, -1 removed lines

@@ -23,5 +23,5 @@
 $publisher = new SyncPublisher($driver, 'xchange');

 

 for ($i = 0; $i < $argv[1]; ++$i) {

-    echo $publisher->publish('event #'.$i, '', ['test' => 'testValue'])."\n";

+    echo $publisher->publish('event #' . $i, '', ['test' => 'testValue']) . "\n";

 }

examples/sync-message-sender-amqplib.php

Spacing +1 added lines, -1 removed lines

@@ -19,5 +19,5 @@
 $publisher = new SyncPublisher($driver, 'xchange');

 

 for ($i = 0; $i < $argv[1]; ++$i) {

-    echo $publisher->publish('event #'.$i, '', ['test' => 'testValue'])."\n";

+    echo $publisher->publish('event #' . $i, '', ['test' => 'testValue']) . "\n";

 }