Module: Phobos::BatchHandler
- Defined in:
- lib/phobos/batch_handler.rb
Defined Under Namespace
Modules: ClassMethods
Class Method Summary collapse
Instance Method Summary collapse
- #around_consume_batch(payloads, metadata) {|payloads, metadata| ... } ⇒ Object
- #consume_batch(_payloads, _metadata) ⇒ Object
Class Method Details
.included(base) ⇒ Object
5 6 7 |
# File 'lib/phobos/batch_handler.rb', line 5 def self.included(base) base.extend(ClassMethods) end |
Instance Method Details
#around_consume_batch(payloads, metadata) {|payloads, metadata| ... } ⇒ Object
13 14 15 |
# File 'lib/phobos/batch_handler.rb', line 13 def around_consume_batch(payloads, ) yield payloads, end |
#consume_batch(_payloads, _metadata) ⇒ Object
9 10 11 |
# File 'lib/phobos/batch_handler.rb', line 9 def consume_batch(_payloads, ) raise NotImplementedError end |