anchor.diff:      disable_on_subscribe(),
       ok = gen_tcp:close(Socket1).
   
  -session_cleanup_test(_) ->
  -    Connect1 = packet:gen_connect("clean-qos1-test", [{keepalive,60}, {clean_session, false}]),
  -    Connect2 = packet:gen_connect("clean-qos1-test", [{keepalive,60}, {clean_session, true}]),
  +session_cleanup_test(Cfg) ->
  +    ClientId = vmq_cth:ustr(Cfg) ++ "clean-qos1-test",
  +    Connect1 = packet:gen_connect(ClientId, [{keepalive,60}, {clean_session, false}]),
  +    Connect2 = packet:gen_connect(ClientId, [{keepalive,60}, {clean_session, true}]),
       Connack = packet:gen_connack(0),
       Disconnect = packet:gen_disconnect(),
       Subscribe = packet:gen_subscribe(109, "qos1/clean_session/test", 1),
       Suback = packet:gen_suback(109, 1),
       {ok, Socket} = packet:do_client_connect(Connect1, Connack, []),
  -    enable_on_publish(),
  -    enable_on_subscribe(),
       ok = gen_tcp:send(Socket, Subscribe),
       ok = packet:expect_packet(Socket, "suback", Suback),
       ok = gen_tcp:send(Socket, Disconnect),
  
positive.code:     vmq_test_utils:setup(),
      vmq_server_cmd:set_config(allow_anonymous, true),
      vmq_server_cmd:set_config(retry_interval, 10),
      vmq_server_cmd:listener_start(1888, []),
      Config.
  
  end_per_testcase(_, Config) ->
      vmq_test_utils:teardown(),
      Config.
  
  all() ->
      [clean_session_qos1_test,
       session_cleanup_test,
       session_present_test].
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  %%% Actual Tests
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  clean_session_qos1_test(_) ->
      Connect = packet:gen_connect("clean-qos1-test", [{keepalive,60}, {clean_session, false}]),
      Connack1 = packet:gen_connack(0),
      Connack2 = packet:gen_connack(true, 0),
      Disconnect = packet:gen_disconnect(),
  
negative.code: -module(vmq_clean_session_SUITE).
  
  -compile(export_all).
  -compile(nowarn_export_all).
  
  %% ===================================================================
  %% common_test callbacks
  %% ===================================================================
  init_per_suite(Config) ->
      cover:start(),
      [{ct_hooks, vmq_cth} | Config].
  
  
  end_per_suite(_Config) ->
      _Config.
  