anchor.diff:  
   exec_task(<<"PUB">>,Map) ->
   
  -    Ts=maps:get(<<"delay">>,Map),
  +    Ts=proplists:get_value(<<"delay">>,Map),
   
       exec_publish(Ts,Map);
       
  
positive.code: 
  
  exec_publish(0,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),
          real_publish(Qname,MemItem);
  
negative.code:     io:format(" starting...\n").
  
  select_task(Data) ->
      Mapx=jiffy:decode(Data),
      {Map} = Mapx,
      Cmd=proplists:get_value(<<"cmd">>,Map,[]),
      exec_task(Cmd,Map).
      
  exec_task(<<"SUB">>,Map) ->
      Qname=proplists:get_value(<<"qname">>,Map),
      pg2:create(Qname),
      pg2:join(Qname,self()),
      R = jiffy:encode({[{<<"cmd">>, <<"oksub">>},{<<"qname">>,Qname}]}),    
  