Evaneos / Burrow

examples/sync-message-worker.php

Indentation +4 added lines, -4 removed lines

@@ -24,10 +24,10 @@
 $logger->pushHandler(new StreamHandler('php://output', 0));

 

 $driver = DriverFactory::getDriver([

-   'host' => 'default',

-   'port' => '5672',

-   'user' => 'guest',

-   'pwd' => 'guest'

+    'host' => 'default',

+    'port' => '5672',

+    'user' => 'guest',

+    'pwd' => 'guest'

 ]);

 

 $handlerBuilder = new HandlerBuilder($driver);

examples/async-message-sender.php

Spacing +1 added lines, -1 removed lines

@@ -23,5 +23,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/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/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";

 }