anchor.diff:  
   exec_task(<<"PUB">>,Map) ->
   
  -    Ts=maps:get(<<"delay">>,Map),
  +    Ts=proplists:get_value(<<"delay">>,Map),
   
       exec_publish(Ts,Map);
       
  
positive.code:     io:format(" starting...\n").
  
  select_task(Data) ->
      Map=jiffy:decode(Data,[return_maps]),
      Cmd=maps:get(<<"cmd">>,Map),
      exec_task(Cmd,Map).
      
  exec_task(<<"SUB">>,Map) ->
      Qname=maps:get(<<"qname">>,Map),
      pg2:create(Qname),
      pg2:join(Qname,self()),
      R = jiffy:encode({[{<<"cmd">>, <<"oksub">>},{<<"qname">>,Qname}]}),    
  
negative.code: exec_task(<<"FET">>,Map) ->
          %Ret = <<"{'cmd':'ok'}">>,
          %io:format("FET cmd recvd."),
          Qname=proplists:get_value(<<"qname">>,Map),
  
          PQname = erlang:iolist_to_binary([Qname,<<"_P">>]), % join 2 bin. string
          pg2:create(PQname),
  