Merge pull request #16 from conduitframework/feature/allow-adapter-to…

…-specify-source Fix to allow adapter to specify the source as in MQTT adapter
conduitframework · Oct 19, 2018 · 3b9c3ae · 3b9c3ae
2 parents 6743634 + f777760
commit 3b9c3ae
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/.gitignore b/.gitignore
@@ -19,3 +19,7 @@ erl_crash.dump
 
 /plt
 .elixir_ls
+
+# Intellij
+/.idea
+*.iml
diff --git a/lib/conduit/broker/incoming_scope.ex b/lib/conduit/broker/incoming_scope.ex
@@ -75,7 +75,7 @@ defmodule Conduit.Broker.IncomingScope do
       |> Enum.map(&{:pipeline, &1})
       |> Enum.reverse()
 
-    plugs = [{route.subscriber, route.opts} | pipeline_plugs] ++ [{:put_source, source}]
+    plugs = [{route.subscriber, route.opts} | pipeline_plugs] ++ [{:put_new_source, source}]
     Conduit.Plug.Builder.compile(plugs, quote(do: & &1))
   end