lib/upperkut/strategies/base.rb in upperkut-0.8.1 vs lib/upperkut/strategies/base.rb in upperkut-1.0.0.rc
- old
+ new
@@ -22,9 +22,23 @@
# Public: Clear all data related to the strategy.
def clear
raise NotImplementedError
end
+ # Public: Confirms that items have been processed successfully.
+ #
+ # items - The Array of items do be confirmed.
+ def ack(_items)
+ raise NotImplementedError
+ end
+
+ # Public: Informs that items have been not processed successfully and therefore must be re-processed.
+ #
+ # items - The Array of items do be unacknowledged.
+ def nack(_items)
+ raise NotImplementedError
+ end
+
# Public: Tells when to execute the event processing,
# when this condition is met so the events are dispatched to
# the worker.
def process?
raise NotImplementedError