Merge pull request #2 from remi-san/burrow4

Compatibility with burrow-v4

composer.json

@@ -18,7 +18,7 @@
         "henrikbjorn/phpspec-code-coverage": "^2.0",
         "doctrine/dbal": "^2.5",
         "doctrine/orm": "^2.5",
-        "evaneos/burrow": "^3.0",
+        "evaneos/burrow": "^4.0",
         "league/event": "^2.1",
         "league/tactician": "^1.0"
     },

src/Amqp/TransactionalQueuePublisher.php

@@ -32,7 +32,7 @@ public function __construct(QueuePublisher $publisher)
     /**
      * {@inheritdoc}
      */
-    public function publish($data, $routingKey = '')
+    public function publish($data, $routingKey = '', array $headers = [])
     {
         if (!$this->running) {
             throw new TransactionException('Cannot publish outside a transaction');
@@ -41,6 +41,7 @@ public function publish($data, $routingKey = '')
         $this->messages[] = [
             'data' => $data,
             'routingKey' => $routingKey,
+            'headers' => $headers
         ];
     }
 
@@ -58,7 +59,7 @@ public function beginTransaction()
     public function commit()
     {
         foreach ($this->messages as $message) {
-            $this->publisher->publish($message['data'], $message['routingKey']);
+            $this->publisher->publish($message['data'], $message['routingKey'], $message['headers']);
         }
         $this->messages = [];
         $this->running = false;

tests/spec/Amqp/TransactionalQueuePublisherSpec.php

@@ -27,15 +27,15 @@ function it_is_not_possible_to_publish_outside_a_transaction()
     function it_should_publish_message_when_committing(QueuePublisher $publisher)
     {
         $this->beginTransaction();
-        $publisher->publish('', '')->shouldBeCalled();
+        $publisher->publish('', '', [])->shouldBeCalled();
         $this->publish('', '');
         $this->commit();
     }
 
     function it_should_not_publish_message_when_rollbacking(QueuePublisher $publisher)
     {
         $this->beginTransaction();
-        $publisher->publish('', '')->shouldNotBeCalled();
+        $publisher->publish('', '', [])->shouldNotBeCalled();
         $this->publish('', '');
         $this->rollback();
     }