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: 
  do_configure(ZK, Framework, Cluster) ->
      ZKNode = coordinated_nodes_zknode(Framework, Cluster),
      do_synchronize_riak_nodes(ZK, ZKNode),
      do_watch_riak_nodes(ZK, ZKNode).
  
negative.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, Framework, Cluster),
      {reply, Nodes, State};
  handle_call(Message, _From, State) ->
      lager:error("Received undefined message in call: ~p", [Message]),
  