anchor.diff:      ok = packet:expect_packet(Socket, "suback", Suback),
       helper_pub_qos1("test-helper", 1, Publish),
       %% should have now received a publish command
  -    ok = packet:expect_packet(Socket, "publish", Publish), %% expect packet, but we don't ack
  +    ok = packet:expect_packet(Socket, "publish", Publish),
  +    %% expect packet, but we don't ack
       %% send our outgoing message, when we disconnect the broker
       %% should get rid of it and ssume we're going to retry
       ok = gen_tcp:send(Socket, Publish2),
  
positive.code: %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  subscribe_test_() ->
      [
  %     {"Publish QoS 1 Success",
  %      ?setup(fun publish_qos1/1)}
  %    ,{"Publish QoS 2 Success",
  %      ?setup(fun publish_qos2/1)}
  %    ,{"Publish B2C disconnect QoS 1 Success",
  %      ?setup(fun publish_b2c_disconnect_qos1/1)}
  %    ,{"Publish B2C disconnect QoS 2 Success",
  %      ?setup(fun publish_b2c_disconnect_qos2/1)}
  %    ,{"Publish B2C timeout QoS 1 Success",
  %      ?setup(fun publish_b2c_timeout_qos1/1)}
  %    ,{"Publish B2C timeout QoS 2 Success",
  %      ?setup(fun publish_b2c_timeout_qos2/1)}
      {"Publish C2B disconnect QoS 2 Success",
        ?setup(fun publish_c2b_disconnect_qos2/1)}
      ,{"Publish C2B timeout QoS 2 Success",
        ?setup(fun publish_c2b_timeout_qos2/1)}
      ,{"Pattern Matching PubSub Test",
        ?setup(fun pattern_matching/1)}
      ].
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
negative.code:     ?_assertEqual(ok, gen_tcp:close(Socket)).
  
  publish_b2c_timeout_qos2(_) ->
      Connect = packet:gen_connect("pub-qos2-timeout-test", [{keepalive, 60}]),
      Connack = packet:gen_connack(0),
      Subscribe = packet:gen_subscribe(3265, "qos2/timeout/test", 2),
      Suback = packet:gen_suback(3265, 2),
      Publish = packet:gen_publish("qos2/timeout/test", 2,
                                   <<"timeout-message">>, [{mid, 1}]),
      PublishDup = packet:gen_publish("qos2/timeout/test", 2,
                                      <<"timeout-message">>,
                                      [{mid, 1}, {dup, true}]),
      Pubrec = packet:gen_pubrec(1),
      Pubrel = packet:gen_pubrel(1),
      PubrelDup = packet:gen_pubrel(1, true),
  