Class: Deimos::Consumer

Inherits:
BaseConsumer show all
Includes:
Phobos::Handler
Defined in:
lib/deimos/consumer.rb

Overview

Parent consumer class.

Instance Method Summary collapse

Methods inherited from BaseConsumer

#decode_key, decoder, key_decoder

Instance Method Details

#around_consume(payload, metadata) ⇒ Object

:nodoc:



17
18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/deimos/consumer.rb', line 17

def around_consume(payload, metadata)
  decoded_payload = payload.dup
  new_metadata = metadata.dup
  benchmark = Benchmark.measure do
    _with_error_span(payload, metadata) do
      new_metadata[:key] = decode_key(metadata[:key]) if self.class.config[:key_configured]
      decoded_payload = payload ? self.class.decoder.decode(payload) : nil
      _received_message(decoded_payload, new_metadata)
      yield decoded_payload, new_metadata
    end
  end
  _handle_success(benchmark.real, decoded_payload, new_metadata)
end

#consume(_payload, _metadata) ⇒ Object

Consume incoming messages.

Parameters:

  • _payload (String)
  • _metadata (Hash)

Raises:

  • (NotImplementedError) 


34
35
36
 
# File 'lib/deimos/consumer.rb', line 34

def consume(_payload, _metadata)
  raise NotImplementedError
end