diff --git a/ydb/core/tx/replication/ydb_proxy/local_proxy/local_proxy.cpp b/ydb/core/tx/replication/ydb_proxy/local_proxy/local_proxy.cpp index 7bcf0a21f46d..c7b83ff21677 100644 --- a/ydb/core/tx/replication/ydb_proxy/local_proxy/local_proxy.cpp +++ b/ydb/core/tx/replication/ydb_proxy/local_proxy/local_proxy.cpp @@ -45,10 +45,16 @@ void TLocalProxyActor::Handle(TEvYdbProxy::TEvAlterTopicRequest::TPtr& ev) { *consumer = c; } - auto callback = [replyTo = ev->Sender, cookie = ev->Cookie, path = path, this](Ydb::StatusIds::StatusCode statusCode, const google::protobuf::Message*) { + auto callback = [ + actorSystem = TActivationContext::ActorSystem(), + replyTo = ev->Sender, + cookie = ev->Cookie, + path = path + ](Ydb::StatusIds::StatusCode statusCode, const google::protobuf::Message*) { NYdb::NIssue::TIssues issues; NYdb::TStatus status(static_cast(statusCode), std::move(issues)); - Send(replyTo, new TEvYdbProxy::TEvAlterTopicResponse(std::move(status)), 0, cookie); + + actorSystem->Send(replyTo, new TEvYdbProxy::TEvAlterTopicResponse(std::move(status)), 0, cookie); }; NGRpcService::DoAlterTopicRequest(std::make_unique(path, Database, std::move(request), callback), *this); @@ -65,7 +71,12 @@ void TLocalProxyActor::Handle(TEvYdbProxy::TEvDescribeTopicRequest::TPtr& ev) { auto request = std::make_unique(); request.get()->set_path(TStringBuilder() << "/" << Database << path); - auto callback = [replyTo = ev->Sender, cookie = ev->Cookie, path = path, this](Ydb::StatusIds::StatusCode statusCode, const google::protobuf::Message* result) { + auto callback = [ + actorSystem = TActivationContext::ActorSystem(), + replyTo = ev->Sender, + cookie = ev->Cookie, + path = path + ](Ydb::StatusIds::StatusCode statusCode, const google::protobuf::Message* result) { NYdb::NIssue::TIssues issues; Ydb::Topic::DescribeTopicResult describe; if (statusCode == Ydb::StatusIds::StatusCode::StatusIds_StatusCode_SUCCESS) { @@ -80,7 +91,8 @@ void TLocalProxyActor::Handle(TEvYdbProxy::TEvDescribeTopicRequest::TPtr& ev) { NYdb::TStatus status(static_cast(statusCode), std::move(issues)); NYdb::NTopic::TDescribeTopicResult r(std::move(status), std::move(describe)); - Send(replyTo, new TEvYdbProxy::TEvDescribeTopicResponse(r), 0, cookie); + + actorSystem->Send(replyTo, new TEvYdbProxy::TEvDescribeTopicResponse(r), 0, cookie); }; NGRpcService::DoDescribeTopicRequest(std::make_unique(path, Database, std::move(request), callback), *this); @@ -97,7 +109,12 @@ void TLocalProxyActor::Handle(TEvYdbProxy::TEvDescribePathRequest::TPtr& ev) { auto request = std::make_unique(); request.get()->set_path(TStringBuilder() << "/" << Database << path); - auto callback = [replyTo = ev->Sender, cookie = ev->Cookie, path = path, this](Ydb::StatusIds::StatusCode statusCode, const google::protobuf::Message* result) { + auto callback = [ + actorSystem = TActivationContext::ActorSystem(), + replyTo = ev->Sender, + cookie = ev->Cookie, + path = path + ](Ydb::StatusIds::StatusCode statusCode, const google::protobuf::Message* result) { NYdb::NIssue::TIssues issues; NYdb::NScheme::TSchemeEntry entry; if (statusCode == Ydb::StatusIds::StatusCode::StatusIds_StatusCode_SUCCESS) { @@ -112,7 +129,8 @@ void TLocalProxyActor::Handle(TEvYdbProxy::TEvDescribePathRequest::TPtr& ev) { NYdb::TStatus status(static_cast(statusCode), std::move(issues)); NYdb::NScheme::TDescribePathResult r(std::move(status), std::move(entry)); - Send(replyTo, new TEvYdbProxy::TEvDescribePathResponse(r), 0, cookie); + + actorSystem->Send(replyTo, new TEvYdbProxy::TEvDescribePathResponse(r), 0, cookie); }; NGRpcService::DoDescribePathRequest(std::make_unique(path, Database, std::move(request), callback), *this); diff --git a/ydb/core/tx/replication/ydb_proxy/local_proxy/local_proxy.h b/ydb/core/tx/replication/ydb_proxy/local_proxy/local_proxy.h index f4cffd75925e..86dccdcb7573 100644 --- a/ydb/core/tx/replication/ydb_proxy/local_proxy/local_proxy.h +++ b/ydb/core/tx/replication/ydb_proxy/local_proxy/local_proxy.h @@ -31,7 +31,6 @@ class TLocalProxyActor STATEFN(StateWork); - private: const TString Database; TString LogPrefix;