anchor.diff:      lager:info("Replication Modes = ~p", [ModeResA]),
       lager:info("Replication Modes = ~p", [ModeResB]),
   
  +
       {ok, {_IP, BPort}} = rpc:call(BFirst, application, get_env,
                                     [riak_core, cluster_mgr]),
       repl_helpers:connect_clusters13(LeaderA, ANodes, BPort, "B"),
  
positive.code:     ?assertEqual(Object4A, proplists:get_value(content,Obj15)),
      pass.
  
  enable_pg(SourceLeader, SinkName, ANodes, BNodes) ->
      set_proxy_get(SourceLeader, "enable", SinkName, ANodes, BNodes).
  
  disable_pg(SourceLeader, SinkName, ANodes, BNodes) ->
      set_proxy_get(SourceLeader, "disable", SinkName, ANodes, BNodes).
  
  set_proxy_get(SourceLeader, EnableOrDisable, SinkName, ANodes, BNodes) ->
      PGEnableResult = rpc:call(SourceLeader, riak_repl_console, proxy_get,
  
negative.code:     erlcloud_s3:delete_object(?TEST_BUCKET, "object_one", U1C1Config),
  
      lager:info("enable proxy_get"),
      enable_pg(LeaderA, "B", ANodes, BNodes, BPort),
  
      lager:info("delete object_two while clusters are connected"),
      erlcloud_s3:delete_object(?TEST_BUCKET, "object_two", U1C1Config),
  