Added ACK to rabbitmq driver

tomaj · Sep 2, 2016 · 9cf3bda · 9cf3bda
1 parent b145e1e
commit 9cf3bda
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -4,6 +4,12 @@ Updates should follow the [Keep a CHANGELOG](http://keepachangelog.com/) princip
 
 ## [Unreleased][unreleased]
 
+## 1.0.0 - 2016-09-02
+
+### Added
+
+* First stable version
+* Added ACK to rabbitmq driver
 
 ## 0.4.0 - 2016-04-26
 

diff --git a/src/Driver/RabbitMqDriver.php b/src/Driver/RabbitMqDriver.php
@@ -65,6 +65,7 @@ public function wait(Closure $callback)
             function ($rabbitMessage) use ($callback) {
                 $message = $this->serializer->unserialize($rabbitMessage->body);
                 $callback($message);
+                $rabbitMessage->delivery_info['channel']->basic_ack($rabbitMessage->delivery_info['delivery_tag']);
             }
         );