Packages

conduit

0.8.0
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 subscriber.ex
Raw

lib/conduit/subscriber.ex 

defmodule Conduit.Subscriber do

  @moduledoc """

  Provides functions and macros for handling incoming messages

  """



  @callback process(Conduit.Message.t, Conduit.Plug.opts) :: Conduit.Message.t



  @doc """

  Defines default implementations for the `Conduit.Plug` and `Conduit.Subscriber` behavior

  """

  defmacro __using__(_opts) do

    quote do

      use Conduit.Plug.Builder

      @behaviour Conduit.Subscriber



      def call(message, next, opts) do

        process(message, opts)

      end



      def process(message, _opts) do

        message

      end



      defoverridable [process: 2]

    end

  end

end