module Phobos::Test::Helper
Constants
- GROUP
- TOPIC
Public Instance Methods
process_message(handler:, payload:, metadata: {}, force_encoding: nil)
click to toggle source
# 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