Packages

reactive_commons

0.7.1
1.5.0 1.4.1 1.4.0 1.3.0 1.2.1 1.2.0 1.1.0 1.0.2 1.0.0 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.2 0.6.1

Domain driven async abstractions like Domain Event Bus, Event subscriptions/emit, Async Command handling and Async Req/Reply.

HexDocs

Current section

Files

Jump to
Readme
19 Versions
4 Dependencies
Dependants
Files
Activity
reactive_commons lib reactive_commons api domain_event_bus.ex
Raw

lib/reactive_commons/api/domain_event_bus.ex 

defmodule DomainEventBus do

  @moduledoc """

    This module allows the domain events emission.

  """

  @domain_events_exchange "domainEvents"



  def emit(event = %DomainEvent{name: name}) do

    msg = OutMessage.new(

      headers: headers(),

      exchange_name: @domain_events_exchange,

      routing_key: name,

      payload: Poison.encode!(event)

    )

    case MessageSender.send_message(msg) do

      :ok -> :ok

      other -> {:emit_fail, other}

    end

  end





  def headers() do

    [{MessageHeaders.h_SOURCE_APPLICATION, :longstr, MessageContext.config().application_name}]

  end



end