Chatwoot/app/dispatchers/async_dispatcher.rb

23 lines
606 B
Ruby
Raw Normal View History

class AsyncDispatcher < BaseDispatcher
def dispatch(event_name, timestamp, data)
EventDispatcherJob.perform_later(event_name, timestamp, data)
end
def publish_event(event_name, timestamp, data)
event_object = Events::Base.new(event_name, timestamp, data)
publish(event_object.method_name, event_object)
end
def listeners
2020-09-08 05:54:08 +00:00
[
CampaignListener.instance,
CsatSurveyListener.instance,
EventListener.instance,
HookListener.instance,
InstallationWebhookListener.instance,
NotificationListener.instance,
WebhookListener.instance
]
end
end