anchor.diff:  			Requester ! {self(), Result},
               instance_manager_loop(RackPid, {busy, []}, WaitThreshold, _RubyCmd, {RequestCount+1, _MaxRequests});
   		terminate -> 
  -            pg2:get_closest_pid(request_pool) ! terminate,
  +            pg2_ext:get_next_pid(request_pool) ! terminate,
   			instance_manager_loop(RackPid, {clogged, []}, WaitThreshold, _RubyCmd, {RequestCount, _MaxRequests})
       end;
   instance_manager_loop(RackPid, {clogged, [_TimerRef | QueuedRequests]}, WaitThreshold, _RubyCmd, {RequestCount, _MaxRequests}) ->
       %% Send all requests queued in RequestList to be handled
       %% by the backup request pool of ruby instances.
  -    [pg2:get_closest_pid(request_pool) ! QueuedRequestData || QueuedRequestData <- lists:reverse(QueuedRequests)],
  +    [pg2_ext:get_next_pid(request_pool) ! QueuedRequestData || QueuedRequestData <- lists:reverse(QueuedRequests)],
   
       receive
   		{Requester, {request, Req}} -> 
  -            pg2:get_closest_pid(request_pool) ! {Requester, {request, Req}},
  +            pg2_ext:get_next_pid(request_pool) ! {Requester, {request, Req}},
   			instance_manager_loop(RackPid, {clogged, []}, WaitThreshold, _RubyCmd, {RequestCount, _MaxRequests});
   		{RackPid, Requester, Result} -> 
               %% Received response from current request.
  
positive.code:     RequestPoolSize = list_to_integer(proplists:get_value("request_pool_size", SConf#sconf.opaque, 10)),
  
  	%% Create a process group for the request pool
  	pg2:create(request_pool),
  
      %% Spawn process to add instance managers for ruby instances
      spawn(?MODULE, add_instance_managers, [RequestPoolSize, SConf]),
  
negative.code: 	%% Spawn a process to run the rack instance
  	RackPid = spawn_ruby_instance(Cmd),
  	%% Join the rack instance manager to the process group
  	case pg2_ext:join(request_pool, self()) of
  		{error, Error} ->
  			io:format("Error occurred trying to join process group: ~p~n", [Error]);
  		_ ->
  