anchor.diff:  all() ->
       ?ALL([
           subscribe_on_dir_test,
  -        subscribe_on_replication_info_test,
           subscribe_on_user_root_test,
           subscribe_on_user_root_filter_test,
           subscribe_on_new_space_test,
           subscribe_on_new_space_filter_test,
  -        events_on_conflicts_test
  +        events_on_conflicts_test,
  +        subscribe_on_replication_info_test
       ]).
   
   -define(CONFLICTING_FILE_NAME, <<"abc">>).
  
positive.code: 
      rpc:call(Worker1, fslogic_event_emitter, emit_file_attr_changed, [file_ctx:new_by_guid(SpaceGuid), []]),
      ?assertEqual(ExpectedAns, receive_file_attr_changed_event()),
      ?assertEqual(ok, ssl:send(Sock,
          fuse_test_utils:generate_subscription_cancellation_message(0, get_seq(Config, User), -Seq1))),
      ?assertEqual(ok, ssl:close(Sock)),
      ok.
  
  
negative.code: 
      rpc:call(Worker1, file_meta, make_space_exist, [<<"space_id", SpaceNum/binary>>]),
      ?assertEqual(ExpectedAns, receive_file_attr_changed_event()),
  
      ?assertEqual(ok, ssl:send(Sock,
          fuse_test_utils:generate_subscription_cancellation_message(0, get_seq(Config, User), -Seq1))),
      ?assertMatch({ok, []},
          rpc:call(Worker1, subscription_manager, get_subscribers, [SubscriptionRoutingKey, undefined]), 10),
      ?assertEqual(ok, ssl:close(Sock)),
      ok.
  
  