Evaneos / Burrow

src/Driver/PhpAmqpLibDriver.php

Doc Comments +1 added lines, -1 removed lines

@@ -278,7 +278,7 @@
     /**
      * @param AMQPMessage $message
      *
-     * @return array
+     * @return \string[]
      */
     private static function getHeaders(AMQPMessage $message)
     {

src/Message.php

Doc Comments +1 added lines, -1 removed lines

@@ -85,7 +85,7 @@
     }
 
     /**
-     * @return array
+     * @return string[]
      */
     public function getHeaders()
     {

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/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');