anchor.diff:  
   init([]) ->
       lmq_queue:start(),
  +    process_flag(trap_exit, true),
       {ok, []}.
   
   handle_call({push, Data}, _From, Puller) ->
  
positive.code:     end,
      case lmq_queue:dequeue() of
          empty -> delay_response(SrvPid, From);
          Message -> gen_server:reply(From, Message)
      end.
  
negative.code:     end, Puller),
      {noreply, Puller}.
  
  handle_info({'EXIT', Pid, Reason}, Puller) ->
      {noreply, Puller -- [Pid]};
  handle_info(Info, Puller) ->
      io:format("unexpected message received: ~p~n", [Info]),
      {noreply, Puller}.
  
  terminate(_Reason, _State) ->
      ok.
  
  delay_response(SrvPid, From) ->
      {Pid, _} = From,
      link(Pid),
      Timeout = lmq_queue:waittime(),
      receive
          {lmq, SrvPid, wake} -> ok
  