diff --git a/ydb/core/persqueue/writer/partition_chooser_impl__abstract_chooser_actor.h b/ydb/core/persqueue/writer/partition_chooser_impl__abstract_chooser_actor.h index 4b385f779cda..0e975c6cec67 100644 --- a/ydb/core/persqueue/writer/partition_chooser_impl__abstract_chooser_actor.h +++ b/ydb/core/persqueue/writer/partition_chooser_impl__abstract_chooser_actor.h @@ -207,7 +207,7 @@ class TAbstractPartitionChooserActor: public TActorBootstrapped { TRACE_EVENT(NKikimrServices::PQ_PARTITION_CHOOSER); switch (ev->GetTypeRewrite()) { HFunc(NKqp::TEvKqp::TEvQueryResponse, HandleUpdate); - sFunc(TEvents::TEvPoison, ScheduleStop); + SFunc(TEvents::TEvPoison, TThis::Die); } } @@ -237,7 +237,7 @@ class TAbstractPartitionChooserActor: public TActorBootstrapped { HFunc(NKikimr::TEvPQ::TEvCheckPartitionStatusResponse, Handle); HFunc(TEvTabletPipe::TEvClientConnected, HandleOwnership); HFunc(TEvTabletPipe::TEvClientDestroyed, HandleOwnership); - sFunc(TEvents::TEvPoison, ScheduleStop); + SFunc(TEvents::TEvPoison, TThis::Die); } }