Module: Phobos::BatchHandler

Defined in:: lib/phobos/batch_handler.rb

Defined Under Namespace

Modules: ClassMethods

Instance Method Summary collapse

Instance Method Details

#around_consume_batch(payloads, metadata) {|Array, Hash<String, Object>| ... } ⇒ `void`

This method returns an undefined value.

Parameters:

payloads (Array)
metadata (Hash<String, Object>)

Yields:

(Array, Hash<String, Object>)



21
22
23

# File 'lib/phobos/batch_handler.rb', line 21

def around_consume_batch(payloads, metadata)
  yield payloads, metadata
end

#consume_batch(_payloads, _metadata) ⇒ `void`

This method returns an undefined value.

Parameters:

_payloads (Array)
_metadata (Hash<String, Object>)

Raises:

(NotImplementedError)



13
14
15

# File 'lib/phobos/batch_handler.rb', line 13

def consume_batch(_payloads, _metadata)
  raise NotImplementedError
end