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

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/queue-config-pecl.php

Spacing +1 added lines, -1 removed lines

@@ -16,4 +16,4 @@
 $admin->declareExchange($exchangeName);

 $admin->declareAndBindQueue($exchangeName, $queueName);

 

-echo 'Added queue "'.$queueName.'" to exchange'."\n";

+echo 'Added queue "' . $queueName . '" to exchange' . "\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";

 }