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