anchor.diff:                        end, Active1)
                     end,
       lists:foreach(SymmetryFun, Nodes),
  +
  +    %% Verify forward message functionality.
  +    lists:foreach(fun({_Name, Node}) ->
  +                    ok = check_forward_message(Node, Manager)
  +                  end, Nodes),
   
       %% Stop nodes.
       stop(Nodes),
  
positive.code:                   end,
      lists:foreach(SymmetryFun, Nodes),
  
      %% Stop nodes.
      stop(Nodes),
  
  
negative.code: 
      StartFun = fun({_Name, Node}) ->
                          %% Start partisan.
                          {ok, _} = rpc:call(Node, application, ensure_all_started, [partisan]),
                          %% Start a dummy registered process that saves in the environment
                          %% whatever message it gets, it will only do this *x* amount of times
                          %% *x* being the number of nodes present in the cluster
                          Pid = rpc:call(Node, erlang, spawn,
                                         [fun() ->
                                              lists:foreach(fun(_) ->
                                                  receive
                                                      {'$gen_cast', {store, N}} ->
                                                          %% save the number in the environment
                                                          application:set_env(partisan, forward_message_test, N)
                                                  end
                                              end, lists:seq(1, length(NodeNames)))
                                          end]),
                          true = rpc:call(Node, erlang, register, [store_proc, Pid]),
                          ct:pal("registered store_proc on pid ~p, node ~p",
                                 [Pid, Node])
                 end,
      lists:foreach(StartFun, Nodes),
  
      ct:pal("Clustering nodes."),
  