Packages

conduit

0.10.3
0.12.10 0.12.9 0.12.8 0.12.7 0.12.6 0.12.5 0.12.4 0.12.3 0.12.2 0.12.1 0.12.0 0.11.0 0.10.8 0.10.7 0.10.6 0.10.5 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.1 0.1.0

Message queue framework, with support for middleware and multiple adapters.

HexDocs

Current section

Files

Jump to
Readme
39 Versions
3 Dependencies
5 Dependants
Files
Activity
conduit lib conduit test_adapter.ex
Raw

lib/conduit/test_adapter.ex 

defmodule Conduit.TestAdapter do

  use Conduit.Adapter

  use Supervisor

  @moduledoc """

  This module is intended to be used instead of a normal adapter in tests.



  See `Conduit.Test` for details.

  """



  @doc false

  def start_link(broker, topology, subscribers, opts) do

    Supervisor.start_link(__MODULE__, [broker, topology, subscribers, opts])

  end



  @doc false

  def init(opts) do

    import Supervisor.Spec



    process = Application.get_env(:conduit, :shared_test_process)

    if process, do: send(process, {:adapter, opts})



    supervise([], strategy: :one_for_one)

  end



  @doc """

  Sends a publish message to the current process or the shared_test_process

  if that is configured.

  """

  def publish(message, config, opts) do

    process = Application.get_env(:conduit, :shared_test_process, self())

    send(process, {:publish, message, config, opts})



    message

  end

end