module EventRouter::Publisher

Constants

ADAPTERS

Public Instance Methods

delivery_adapter(adapter) click to toggle source
# File lib/event_router/publisher.rb, line 24
def delivery_adapter(adapter)
  EventRouter.configuration.delivery_adapter_class(adapter)
end
publish(events, adapter:) click to toggle source
# File lib/event_router/publisher.rb, line 12
def publish(events, adapter:)
  adapter_class = delivery_adapter(adapter)

  Array(events).each { |event| adapter_class.deliver(event) }
end
publish_async(events, adapter:) click to toggle source
# File lib/event_router/publisher.rb, line 18
def publish_async(events, adapter:)
  adapter_class = delivery_adapter(adapter)

  Array(events).each { |event| adapter_class.deliver_async(event) }
end