Module: Phobos::Test::Helper

Defined in:
lib/phobos/test/helper.rb

Constant Summary collapse

TOPIC = 
'test-topic'
GROUP = 
'test-group'

Instance Method Summary collapse

Instance Method Details

#process_message(handler:, payload:, metadata: {}, force_encoding: nil) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/phobos/test/helper.rb', line 9

def process_message(handler:, payload:, metadata: {}, force_encoding: nil)
  listener = Phobos::Listener.new(
    handler: handler,
    group_id: GROUP,
    topic: TOPIC, force_encoding: force_encoding
  )

  message = Kafka::FetchedMessage.new(
    message: Kafka::Protocol::Message.new(value: payload, key: nil, offset: 13),
    topic: TOPIC, partition: 0
  )

  Phobos::Actions::ProcessMessage.new(
    listener: listener,
    message: message,
    listener_metadata: metadata
  ).execute
end