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; + } }; /**