onError should be overloaded by subclass, otherwise callback installe…

…rs are no longer available for that class.
CopernicaMarketingSoftware · Sep 21, 2018 · ba532e0 · ba532e0
1 parent 757feb1
commit ba532e0
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/include/amqpcpp/deferredget.h b/include/amqpcpp/deferredget.h
@@ -103,6 +103,19 @@ class DeferredGet : public DeferredExtReceiver, public std::enable_shared_from_t
         // allow chaining
         return *this;
     }
+
+    /**
+     *  Register a function to be called when an error occurs. This should be defined, otherwise the base methods are used.
+     *  @param  callback
+     */
+    DeferredGet &onError(const ErrorCallback &callback)
+    {
+        // store the callback
+        _errorCallback = callback;
+
+        // allow chaining
+        return *this;
+    }
 
     /**
      *  Register a function to be called when a message arrives