gistfile1.txt

-module(pubsub_srv).

start_link() -> 
  {ok,PID} = eredis_sub:start_link(),
  register(eredispid,PID),
  _Receiver = spawn_link(fun () ->
                                  eredis_sub:controlling_process(PID),
                                  receiver(PID)
                          end),
  {ok, PID}.

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

subscribe_channel(Channel) -> 
   Sub = whereis(eredispid),
   eredis_:sub:subscribe(Sub, [<<Channel>>]).