Permalink
Browse files

The Pid parameter wasn't handled correctly in both mnesia and amqp ba…

…ckend
  • Loading branch information...
phorque
phorque committed Dec 6, 2010
1 parent 45ff150 commit d8ff1f536d797d6514f49e2f3741c3e21953597a
Showing with 2 additions and 2 deletions.
  1. +1 −1 src/backends/pubsub/amqp/amqp_pubsub.erl
  2. +1 −1 src/backends/pubsub/mnesia/mnesia_pubsub.erl
@@ -40,7 +40,7 @@ init([]) ->
publish(Location, Type, From, Message) ->
gen_server:call(?MODULE, {publish, Location, Type, From, Message}).
-subscribe(Location, Search, From, Types, Uid, _Start, _End, _Parent, Pid) ->
+subscribe(Pid, Location, Search, From, Types, Uid, _Start, _End, _Parent) ->
lists:foreach(fun(Type) ->
case Location of
[Org, Meeting] ->
@@ -32,7 +32,7 @@ init([]) ->
publish(Location, Type, From, Message) ->
gen_server:call(?MODULE, {publish, Location, Type, From, Message}).
-subscribe(Location, Search, From, Types, Uid, _Start, _End, _Parent, Pid) ->
+subscribe(Pid, Location, Search, From, Types, Uid, _Start, _End, _Parent) ->
[gen_server:cast(?MODULE, {subscribe, Location, Uid, Search, Type, From, Pid}) || Type <- Types].
unsubscribe(Pid) ->

0 comments on commit d8ff1f5

Please sign in to comment.