anchor.diff:  
   
   exec_task(<<"ACK">>,Map) ->
  -    Uid=maps:get(<<"uid">>,Map),
  -    Qname=maps:get(<<"qname">>,Map),
  +    Uid=proplists:get_value(<<"uid">>,Map),
  +    Qname=proplists:get_value(<<"qname">>,Map),
       ets:insert(etzel_delset, {Uid, ok}),
       gen_server:call(whereis(filegen),{del,Qname,Uid}),
       R = jiffy:encode({[{<<"cmd">>, <<"okack">>},{<<"uid">>,Uid},{<<"qname">>,Qname}]}),    
       R=R;
   
   exec_task(<<"ISLP">>,Map) ->
  -    Qname=maps:get(<<"qname">>,Map),
  +    Qname=proplists:get_value(<<"qname">>,Map),
       SQname = erlang:iolist_to_binary([Qname,<<"_S">>]),
       pg2:create(SQname),
       pg2:join(SQname,self()),
  
positive.code: 
  
  exec_publish(Ts,Map)->
          Qname=maps:get(<<"qname">>,Map),
          Msg=maps:get(<<"msg">>,Map),
          Delay=maps:get(<<"delay">>,Map),
          Expires=maps:get(<<"expires">>,Map),
          {MemItem,Uid}=gen_msg(Msg,Expires),
          push_to_disk(Qname,Uid,0,Delay,Expires,Msg),
          timer:apply_after(Ts*1000,qin,real_publish,[Qname,MemItem]),
  
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),
  