anchor.diff:      ZKNode = binary_to_list(ZKNodeBin),
       lager:info("Received coordinated node change event: ~p. "
           "Synchronizing Riak Nodes...", [Message]),
  -    Changes = do_synchronize_riak_nodes(ZK, ZKNode),
  +    Changes = do_synchronize_riak_nodes(ZK, ZKNode, Framework, Cluster),
       lager:info("Synchronized Riak nodes, changes: ~p", [Changes]),
       erlzk:get_children(ZK, ZKNode, self()),
       {noreply, State};
  
positive.code: handle_call({get_riak_nodes}, _From,
          State=#state{zk=ZK, framework=Framework, cluster=Cluster}) ->
      ZKNode = coordinated_nodes_zknode(Framework, Cluster),
      Nodes = do_get_riak_nodes(ZK, ZKNode),
      {reply, Nodes, State};
  handle_call(Message, _From, State) ->
      lager:error("Received undefined message in call: ~p", [Message]),
  
negative.code: %%% Private
  %%%===================================================================
  
  coordinated_nodes_zknode(Framework, _Cluster) ->
      Path = "/riak/frameworks/~s/coordinator/coordinatedNodes",
      lists:flatten(io_lib:format(Path,[Framework])).
  
  do_get_riak_nodes(ZK, ZKNode0, Framework, Cluster) ->
      CNodes = get_children(ZK, ZKNode0),
  
      F1 = fun(CNode, Acc) ->
          ZKNode1 = lists:flatten(io_lib:format("~s/~s",[ZKNode0, CNode])),
          NodeJson = get_data(ZK, ZKNode1),
          {struct,[{<<"FrameworkName">>,_NFramework},
                   {<<"ClusterName">>,NCluster},
                   {<<"NodeName">>,NodeName},
                   {<<"DisterlPort">>,_DistErlPort},
                   {<<"PBPort">>,PBPort},
                   {<<"HTTPPort">>,HTTPPort},
                   {<<"Hostname">>,HostName}]} = mochijson2:decode(NodeJson),
  
          case binary_to_list(NCluster) of
              Cluster ->
                  [[{name, list_to_atom(binary_to_list(NodeName))},
                   {protobuf,
                     [{host, HostName}, {port, PBPort}]},
                   {http,
                      [{host, HostName}, {port, HTTPPort}]}]|Acc];
              _ -> Acc
          end
  
          end,
      Nodes = lists:foldl(F1, [], CNodes),
      Nodes.
  
  do_synchronize_riak_nodes(ZK, ZKNode, Framework, Cluster) ->
      AvailableNodes = do_get_riak_nodes(ZK, ZKNode, Framework, Cluster),
      HTTPSt = bal_proxy:get_state(balance_http),
      ProxyHTTPNodes = HTTPSt#bp_state.be_list,
      PBSt = bal_proxy:get_state(balance_protobuf),
  