anchor.diff:                    {ok, _} -> Pubs
                 end,
       NewSubs = case dict:find(Channel, Subs) of
  -                  error -> dict:store(Channel, SubsriberPid, Subs);
  +                  error -> dict:store(Channel, SubscriberPid, Subs);
                     {ok, _} -> Subs
                 end,
       State#state{publishers = NewPubs, subscribers = NewSubs};
  
positive.code:              State
      end;
  
  process_message(_, State) ->
      io:format("unknown message~n"),
      State .
  
negative.code: 
  handle_cast({process_message, Message}, State) ->
      StateNew = try jsx:decode(Message) of
                     Msg -> 
                         process_message(Msg, State)
                 catch _:_ ->
                           State
                 end,
  