Module: Maitredee::Adapters::TestAdapter::SubscriberTesting

Included in:
Subscriber
Defined in:
lib/maitredee/adapters/test_adapter.rb

Instance Method Summary collapse

Instance Method Details

#test(body:, event_name: nil, message_id: SecureRandom.uuid, sent_at: Time.now, primary_key: nil) ⇒ Object

simple api to test subscribers

  RecipeSubscriber.test(body: { id: 1 })



52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
 
# 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