anchor.diff:      Publish1 = packet:gen_publish("dlvr/rewrite/payload", 0, <<"hello world">>, []),
       ok = packet:expect_packet(Socket, "publish", Publish1),
   
  -    disable_on_publish(),
  +    disable_auth_on_publish(),
       disable_on_deliver(),
  -    disable_on_subscribe(),
  +    disable_auth_on_subscribe(),
       ok = gen_tcp:close(Socket).
   
   on_deliver_rewrite_packet_test(_) ->
  
positive.code:     Publish1 = packet:gen_publish("dlvr/rewrite/payload", 0, <<"hello world">>, []),
      ok = packet:expect_packet(Socket, "publish", Publish1),
  
      disable_on_publish(),
      disable_on_deliver(),
      disable_on_subscribe(),
      ok = gen_tcp:close(Socket).
  
  
  
negative.code: %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  %%% Helper
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  enable_auth_on_subscribe() ->
      vmq_plugin_mgr:enable_module_plugin(
        auth_on_subscribe, ?MODULE, hook_auth_on_subscribe, 3).
  enable_auth_on_publish() ->
      vmq_plugin_mgr:enable_module_plugin(
        auth_on_publish, ?MODULE, hook_auth_on_publish, 6).
  enable_on_deliver() ->
      vmq_plugin_mgr:enable_module_plugin(
        on_deliver, ?MODULE, hook_on_deliver, 4).
  disable_auth_on_subscribe() ->
      vmq_plugin_mgr:disable_module_plugin(
        auth_on_subscribe, ?MODULE, hook_auth_on_subscribe, 3).
  disable_auth_on_publish() ->
      vmq_plugin_mgr:disable_module_plugin(
        auth_on_publish, ?MODULE, hook_auth_on_publish, 6).
  disable_on_deliver() ->
  