From 9cf3bda8415203467c1a1e02527187de3f213a9d Mon Sep 17 00:00:00 2001
From: Tomas Majer <tomasmajer@gmail.com>
Date: Fri, 2 Sep 2016 09:09:01 +0200
Subject: [PATCH] Added ACK to rabbitmq driver

---
 CHANGELOG.md                  | 6 ++++++
 src/Driver/RabbitMqDriver.php | 1 +
 2 files changed, 7 insertions(+)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index d3fe38f..d425bdb 100644
--- 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
index ba7a323..ac0ca0a 100644
--- 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']);
             }
         );