anchor.diff:        ?MODULE, [InstanceName], []).
   
   -spec subscribe(InstanceName :: atom(), 
  -				SubscriberPid :: pid(), 
  +				SubscriberRef :: 
  +					pid() | 
  +					port() | 
  +					atom() | % LocalRegName
  +					{LocalRegName :: atom(), Node :: node()}|
  +					{global, GlobalRegName :: term()}, 
   				SendMethod :: send_method() ) -> ok.
  -subscribe(InstanceName, SubscriberPid, SendMethod) 
  -  when is_pid(SubscriberPid) ->
  -	Alias=get_global_alias(InstanceName),
  -	case gen_server:call({global, Alias}, 
  -						 {subscribe, SubscriberPid, SendMethod}) of
  -        {error, Reason} -> throw(Reason);
  -        R -> R
  -    end.
  +subscribe(InstanceName, SubscriberRef, SendMethod) ->
  +	SrvName=make_name([InstanceName, receiver, srv]),
  +	case gen_server:call(SrvName, {subscribe, SubscriberRef, SendMethod}) of
  +		{error, Reason} -> throw(Reason);
  +		R -> R
  +	end.
   
   get_global_alias(InstanceName) ->
       SrvName=make_name([InstanceName, receiver, srv]),
  
positive.code: %% ====================================================================
  
  init([InstanceName]) ->
      {ok, #state{global_alias=allocate_global_name(InstanceName, 10)}}.
  
  handle_call({subscribe, SubscriberPid, SendMethod}, 
  			_From, 
  			#state{registry=Reg}=State) ->
  	case lists:keymember(SubscriberPid, 1, Reg) of
  		false -> 
  			SendMethodR=resolve_send_method(SendMethod),
  			{reply, ok, State#state{registry=[{SubscriberPid,SendMethodR}|Reg]}};
  		true -> {reply, {error, already_subscribed}, State}
  	end;
  handle_call(get_global_alias, _From, #state{global_alias=GlbalAlias}=State) ->
  
negative.code: handle_cast(Info, #state{registry=Reg}=State) ->
      Timestamp=now(),
      Event={Timestamp, Info},
      {noreply, State#state{registry=notify_subs(Reg, Event)}}.
  
  handle_info({'DOWN', MonitorRef, process, _Object, _Info}, 
  			#state{registry=Reg}=State) ->
  	Reg1=lists:keydelete(MonitorRef, 3, Reg),
      {noreply, State#state{registry=Reg1}};
  handle_info({global_name_conflict, _Name}, 
              #state{global_alias={InstanceName,_}}=State) ->
      {noreply, 
  