Packages

conduit

0.12.1
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

39 Versions

Jump to
Readme
39 Versions
3 Dependencies
5 Dependants
Files
Activity
Hide whitespace

Compare versions

6 files changed
+4 additions
-6 deletions
  @@ -60,4 +60,4 @@
60 60 {<<"optional">>,false},
61 61 {<<"repository">>,<<"hexpm">>},
62 62 {<<"requirement">>,<<"~> 1.1">>}]]}.
63 - {<<"version">>,<<"0.12.0">>}.
63 + {<<"version">>,<<"0.12.1">>}.
  @@ -14,6 +14,7 @@ defmodule Conduit.Broker do
14 14 @otp_app unquote(opts)[:otp_app] || raise("endpoint expects :otp_app to be given")
15 15 use Supervisor
16 16 use Conduit.Broker.DSL, otp_app: @otp_app
17 + import Conduit.Plug.MessageActions
17 18
18 19 @type route :: atom
19 20 @type message :: Conduit.Message.t()
  @@ -224,6 +224,7 @@ defmodule Conduit.Broker.DSL do
224 224 @doc false
225 225 defmacro __before_compile__(_) do
226 226 quote do
227 + import Conduit.Plug.MessageActions
227 228 unquote(Topology.methods())
228 229 unquote(IncomingScope.methods())
229 230 unquote(OutgoingScope.methods())
  @@ -87,8 +87,6 @@ defmodule Conduit.Broker.IncomingScope do
87 87 end)
88 88 def subscribers, do: @subscribers_map
89 89
90 - import Conduit.Plug.MessageActions, only: [put_source: 3]
91 -
92 90 for route <- @subscribe_routes do
93 91 pipeline = Conduit.Broker.IncomingScope.compile(route)
  @@ -88,8 +88,6 @@ defmodule Conduit.Broker.OutgoingScope do
88 88
89 89 def publish(name, message, opts \\ [])
90 90
91 - import Conduit.Plug.MessageActions, only: [put_new_destination: 3, put_private: 3]
92 -
93 91 for route <- @publish_routes do
94 92 pipeline = Conduit.Broker.OutgoingScope.compile(__MODULE__, route)
Loading more files…