Packages

elixir_structure_manager

0.1.2
1.6.1 1.6.0 1.5.0 1.4.6 1.4.5 1.4.4 1.4.3 1.4.2 1.4.1 1.4.0 1.3.6 1.3.5 1.3.4 1.3.3 1.3.2 1.3.1 1.3.0 1.2.2 1.2.1 1.2.0 1.1.0 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Plugin to generate a clean architecture scaffold.

HexDocs

Current section

Files

Jump to
Readme
30 Versions
1 Dependency
Dependants
Files
Activity
elixir_structure_manager priv templates adapters async_event_bus async_messages.ex
Raw

priv/templates/adapters/async_event_bus/async_messages.ex 

defmodule {app}.Adapters.AsyncMessages do

  @moduledoc false

  # @behaviour Your.Own.Behaviour

  @target "external-service-name"

  @query_name "GetPerson"

  @command_name "RegisterPerson"

  @event_name "PersonRegistered"

  @notification_event_name "ConfigurationChanged"



  @impl true

  def emit(event_data) do

    # it returns :ok when success

    DomainEvent.new(@event_name, event_data)

    |> DomainEventBus.emit()

  end



  @impl true

  def run_remote_task(command_data) do

    # it returns :ok when success

    Command.new(@command_name, command_data)

    |> DirectAsyncGateway.send_command(@target)

  end



  @impl true

  def get_remote_information(query_data) do

    # it returns {:ok, response} when success

    AsyncQuery.new(@query_name, query_data)

    |> DirectAsyncGateway.request_reply_wait(@target)

  end

end