anchor.diff:      ok = gen_tcp:send(Socket, Publish),
       ok = packet:expect_packet(Socket, "puback", Puback),
       ok = gen_tcp:send(Socket, Disconnect),
  -    io:format(user, ".", []),
       publish_random(Nodes, N - 1, Topic, [Payload|Acc]).
   
   receive_publishes(_, _, []) -> ok;
  
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, packet:gen_puback(MsgId)),
              ok = gen_tcp:send(Socket, Disconnect),
              gen_tcp:close(Socket),
              receive_publishes(Nodes ++ [N], Topic, Payloads -- [Payload]);
          {error, _} ->
              receive_publishes(Nodes ++ [N], Topic, Payloads)
  