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