Skip to content

Commit 9cf3bda

Browse files
committed
Added ACK to rabbitmq driver
1 parent b145e1e commit 9cf3bda

File tree

2 files changed

+7
-0
lines changed

2 files changed

+7
-0
lines changed

CHANGELOG.md

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,12 @@ Updates should follow the [Keep a CHANGELOG](http://keepachangelog.com/) princip
44

55
## [Unreleased][unreleased]
66

7+
## 1.0.0 - 2016-09-02
8+
9+
### Added
10+
11+
* First stable version
12+
* Added ACK to rabbitmq driver
713

814
## 0.4.0 - 2016-04-26
915

src/Driver/RabbitMqDriver.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@ public function wait(Closure $callback)
6565
function ($rabbitMessage) use ($callback) {
6666
$message = $this->serializer->unserialize($rabbitMessage->body);
6767
$callback($message);
68+
$rabbitMessage->delivery_info['channel']->basic_ack($rabbitMessage->delivery_info['delivery_tag']);
6869
}
6970
);
7071

0 commit comments

Comments
 (0)