Class: Phobos::Actions::ProcessMessage

Inherits:
Object
  • Object
show all
Defined in:
lib/phobos/actions/process_message.rb

Instance Method Summary collapse

Constructor Details

#initialize(listener:, message:, metadata:, encoding:) ⇒ ProcessMessage 



4
5
6
7
8
9
 
# File 'lib/phobos/actions/process_message.rb', line 4

def initialize(listener:, message:, metadata:, encoding:)
  @listener = listener
  @message = message
  @metadata = metadata
  @encoding = encoding
end

Instance Method Details

#execute ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/phobos/actions/process_message.rb', line 11

def execute
  payload = force_encoding(@message.value)
  decoded_payload = @listener.handler_class.new.before_consume(payload)
  @listener.handler_class.around_consume(decoded_payload, @metadata) do
    @listener.handler_class.new.consume(decoded_payload, @metadata)
  end
end