gistfile1.txt

-module(pubsub_srv).

start_link() -> 
  {ok,PID} = eredis_sub:start_link(),
  register(eredispid,PID),
  {ok, PID}.

receiver(Sub) ->
    receive
        Msg ->
            io:format("received ~p~n", [Msg]),
            ack_message(Sub),
            ?MODULE:receiver(Sub)
    end.

%This is called by other modules
subscribe_channel(Channel) -> 
   Sub = whereis(eredispid),
   _Receiver = spawn_link(fun () ->
                                  eredis_sub:controlling_process(Sub),
                                  eredis_:sub:subscribe(Sub, [<<Channel>>]),
                                  receiver(Sub)
                          end),