anchor.diff:  
   client_communiate_async_test(Config) ->
       % given
  -    [Worker1, _] = ?config(op_worker_nodes, Config),
  +    [Worker1, _] = Workers = ?config(op_worker_nodes, Config),
       Status = #status{
           code = 'VOK',
           description = <<"desc">>
       },
       ServerMsgInternal = #server_message{message_body = Status},
       Self = self(),
  -
  -    % when
       {ok, {Sock, SessionId}} = spawn_ssl_echo_client(Worker1),
  +
  +    % when
       {ok, MsgId} = rpc:call(Worker1, client_communicator, communicate_async,
           [ServerMsgInternal, SessionId, Self]),
       ReceivedMessage =
  
positive.code:     ssl:stop();
  
  end_per_testcase(Case, Config) when Case =:= protobuf_msg_test
      orelse Case =:= multi_message_test ->
      Workers = ?config(op_worker_nodes, Config),
      test_utils:mock_validate(Workers, router),
      test_utils:mock_unload(Workers, router),
  
negative.code:     Cert = ?TEST_FILE(Config, "peer.pem"),
  
      % when
      {ok, Sock} = ssl:connect(?GET_HOST(Worker1), 5555, [binary, {packet, 4},
          {active, true}, {certfile, Cert}, {cacertfile, Cert}]),
      {ok, {certificate_info_message, {ok, CertInfo}}} =
          test_utils:receive_any(timer:seconds(5)),
      ok = ssl:send(Sock, HandshakeReqRaw),
      {ok, {ssl, _, RawHandshakeResponse}} = test_utils:receive_any(timer:seconds(5)),
  
  