anchor.diff:              ok = gen_tcp:send(Socket, packet:gen_puback(MsgId)),
               ok = gen_tcp:send(Socket, Disconnect),
               gen_tcp:close(Socket),
  -            io:format(user, "+", []),
               receive_publishes(Nodes ++ [N], Topic, Payloads -- [Payload]);
           {error, _} ->
               receive_publishes(Nodes ++ [N], Topic, Payloads)
  
positive.code:                                   vmq_reg, stored, [{"", <<"connect-unclean">>}])
             end,
      io:format(user, "!!!!!!!!!!!!!!!!!!! stored msgs before send ~p~n", [Strd()]),
      Payloads = publish_random(Nodes, 50, Topic),
      Ports = fun() -> rpc:multicall([N || {N, _} <-Nodes],
                                    erlang, system_info, [port_count])
             end,
  
negative.code:     ok = gen_tcp:send(Socket, Publish),
      ok = packet:expect_packet(Socket, "puback", Puback),
      ok = gen_tcp:send(Socket, Disconnect),
      publish_random(Nodes, N - 1, Topic, [Payload|Acc]).
  
  receive_publishes(_, _, []) -> ok;
  