Packages

conduit

0.12.9
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 false

  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