module Phobos::BatchHandler
Public Class Methods
included(base)
click to toggle source
# File lib/phobos/batch_handler.rb, line 5 def self.included(base) base.extend(ClassMethods) end
Public Instance Methods
around_consume_batch(payloads, metadata) { |payloads, metadata| ... }
click to toggle source
# File lib/phobos/batch_handler.rb, line 13 def around_consume_batch(payloads, metadata) yield payloads, metadata end
consume_batch(_payloads, _metadata)
click to toggle source
# File lib/phobos/batch_handler.rb, line 9 def consume_batch(_payloads, _metadata) raise NotImplementedError end