Skip to content

Commit 41d771d

Browse files
committed
AMQP: Implement nack()
1 parent 69ef1e7 commit 41d771d

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/msgflo.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -157,7 +157,7 @@ class AmqpEngine final : public Engine, protected AbstractEngine<AmqpEngine> {
157157
}
158158

159159
virtual void nack() override {
160-
throw runtime_error("nack is not implemented for AMQP");
160+
channel.reject(_deliveryTag);
161161
}
162162
};
163163

0 commit comments

Comments
 (0)