anchor.diff:      % Artificially prolong message handling to avoid races between response from
       % the server and connection close.
       test_utils:mock_new(Workers, router),
  -    test_utils:mock_expect(Workers, router, preroute_message,
  -        fun(Msg, SessionId) ->
  +    test_utils:mock_expect(Workers, router, route_message,
  +        fun(Msg) ->
               timer:sleep(2000),
  -            meck:passthrough([Msg, SessionId])
  +            meck:passthrough([Msg])
           end
       ),
   
  
positive.code:     % when
      {ok, {Sock, SessionId}} = spawn_ssl_echo_client(Worker1),
      CommunicateResult = rpc:call(Worker1, communicator, communicate,
          [ServerMsgInternal, SessionId]),
  
      % then
      ?assertMatch({ok, #client_message{message_body = Status}}, CommunicateResult),
  
negative.code: protobuf_msg_test(Config) ->
      % given
      [Worker1 | _] = Workers = ?config(op_worker_nodes, Config),
      test_utils:mock_expect(Workers, router, route_message, fun
          (#client_message{message_body = #events{events = [#event{
              type = #file_read_event{}
          }]}}) -> ok
      end),
      Msg = #'ClientMessage'{
          message_id = <<"0">>,
  