anchor.diff:  handle_cast(_Msg, State) ->
       {noreply, State}.
   
  -handle_info(_Info, State) ->
  +handle_info({deliver_labels, Node}, S0=#state{queues=Queues0, busy=Busy0, myid=MyId}) ->
  +    {NewQueue, NewPending} = deliver_labels(dict:fetch(Node, Queues0), Node, MyId, []),
  +    Queues1 = dict:store(Node, NewQueue, Queues0),
  +    Busy1 = dict:store(Node, NewPending, Busy0),
  +    {noreply, S0#state{queues=Queues1, busy=Busy1}};
  +
  +handle_info(Info, State) ->
  +    lager:info("Weird message: ~p", [Info]),
       {noreply, State}.
   
   terminate(_Reason, _State) ->
  
positive.code: -export([start_link/2]).
  
  -export([handle/1,
           handle/2,
           delayed_delivery_completed/2,
           deliver_delayed/4]).
  
  %% ------------------------------------------------------------------
  %% gen_server Function Exports
  
negative.code: %% ------------------------------------------------------------------
  %% Internal Function Definitions
  %% ------------------------------------------------------------------
  deliver_labels(Queue0, Node, MyId, Deliverables0) ->
      Now = saturn_utilities:now_microsec(),
      case queue:out(Queue0) of
          {empty, Queue0} ->
              propagate_stream(Node, lists:reverse(Deliverables0), MyId),
              {Queue0, false};
          {{value, {Time, Label}}, Queue1} when Time =< Now ->
              deliver_labels(Queue1, Node, MyId, [Label|Deliverables0]);
          {{value, {Time, _Label}}, _Queue1} ->
              propagate_stream(Node, lists:reverse(Deliverables0), MyId),
              NextDelivery = trunc((Time - Now)/1000),
              erlang:send_after(NextDelivery, self(), {deliver_labels, Node}),
              {Queue0, true}
      end.
                 
  propagate_stream(_Node, [], _MyId) ->
      done;
  
  propagate_stream(Node, Stream, MyId) ->
      lager:info("Stream to propagate to ~p: ~p", [Node, Stream]),
      case ?PROPAGATION_MODE of
          naive_erlang ->
              case groups_manager_serv:is_leaf(Node) of
  