From ddee073278c940d49d82d0cfbcc98a6fad0ec034 Mon Sep 17 00:00:00 2001
From: Marcin Gibula <m.gibula@beyond.pl>
Date: Mon, 14 May 2018 21:40:30 +0200
Subject: [PATCH] Add onAck and onNack methods

---
 include/amqpcpp/deferredconfirm.h | 27 ++++++++++++++++++++++++++-
 1 file changed, 26 insertions(+), 1 deletion(-)

diff --git a/include/amqpcpp/deferredconfirm.h b/include/amqpcpp/deferredconfirm.h
index f9f24a4..fc89a06 100644
--- a/include/amqpcpp/deferredconfirm.h
+++ b/include/amqpcpp/deferredconfirm.h
@@ -42,7 +42,6 @@ private:
      */
     void process(BasicAckFrame &frame);
 
-
     /**
      *  Process an ACK frame
      *
@@ -85,6 +84,32 @@ public:
         // allow chaining
         return *this;
     }
+
+    /**
+     *  Callback that is called when the broker confirmed message publication
+     *  @param  callback    the callback to execute
+     */
+    DeferredConfirm &onAck(const AckCallback &callback)
+    {
+        // store callback
+        _ackCallback = callback;
+
+        // allow chaining
+        return *this;
+    }
+
+    /**
+     *  Callback that is called when the broker denied message publication
+     *  @param  callback    the callback to execute
+     */
+    DeferredConfirm &onNack(const NackCallback &callback)
+    {
+        // store callback
+        _nackCallback = callback;
+
+        // allow chaining
+        return *this;
+    }
 };
 
 /**