anchor.diff:      ?assertMatch({ok, [_]},
           rpc:call(Worker1, subscription_manager, get_subscribers, [SubscriptionRoutingKey, undefined]), 10),
   
  -    rpc:call(Worker1, file_meta, make_space_exist, [<<"space_id1">>]),
  +    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))),
  
positive.code: 
      lists:foreach(fun(Seq) ->
          ?assertEqual(ok, ssl:send(Sock,
              fuse_test_utils:generate_subscription_cancellation_message(0, get_seq(Config, 1), -Seq)))
      end, [Seq1, Seq2]),
      ?assertEqual(ok, ssl:close(Sock)),
      ok.
  
negative.code:     Dirname = generator:gen_name(),
  
      DirId = fuse_test_utils:create_directory(Sock, SpaceGuid, Dirname),
      Seq1 = get_seq(Config, <<"user1">>),
      Seq2 = get_seq(Config, <<"user1">>),
      ?assertEqual(ok, ssl:send(Sock,
          fuse_test_utils:generate_file_removed_subscription_message(0, Seq1, -Seq1, DirId))),
      ?assertEqual(ok, ssl:send(Sock,
  