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
 
# File 'lib/deimos/consumer.rb', line 17

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

#consume(_payload, _metadata) ⇒ Object

Consume incoming messages.

Parameters:

  • _payload (String)
  • _metadata (Hash)

Raises:

  • (NotImplementedError) 


32
33
34
 
# File 'lib/deimos/consumer.rb', line 32

def consume(_payload, _metadata)
  raise NotImplementedError
end