module Maitredee::Adapters::TestAdapter::SubscriberTesting
Public Instance Methods
test( body:, event_name: nil, message_id: SecureRandom.uuid, sent_at: Time.now, primary_key: nil )
click to toggle source
simple api to test subscribers “`
RecipeSubscriber.test(body: { id: 1 })
“`
# File lib/maitredee/adapters/test_adapter.rb, line 52 def test( body:, event_name: nil, message_id: SecureRandom.uuid, sent_at: Time.now, primary_key: nil ) message = SubscriberMessage.new( topic_name: topic_name, body: TestAdapter.serialize_argument(body), event_name: event_name, message_id: message_id, sent_at: sent_at.to_i, primary_key: primary_key, schema_name: nil, broker_message_id: message_id, maitredee_version: Maitredee::VERSION, raw_message: nil, adapter_message: nil ) process(message) end