aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/oldmodule/module.cpp
diff options
context:
space:
mode:
authoragorodilov <agorodilov@yandex-team.ru>2022-02-10 16:47:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:09 +0300
commitbd5ef432f5cfb1e18851381329d94665a4c22470 (patch)
treeb83306b6e37edeea782e9eed673d89286c4fef35 /library/cpp/messagebus/oldmodule/module.cpp
parent7a4979e6211c3e78c7f9041d4a9e5d3405343c36 (diff)
downloadydb-bd5ef432f5cfb1e18851381329d94665a4c22470.tar.gz
Restoring authorship annotation for <agorodilov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/oldmodule/module.cpp')
-rw-r--r--library/cpp/messagebus/oldmodule/module.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp
index c335bfaed8..24bd778799 100644
--- a/library/cpp/messagebus/oldmodule/module.cpp
+++ b/library/cpp/messagebus/oldmodule/module.cpp
@@ -848,7 +848,7 @@ EMessageStatus TBusModule::StartJob(TAutoPtr<TBusMessage> message) {
}
void TModuleServerHandler::OnMessage(TOnMessageContext& msg) {
- Module->OnMessageReceived(nullptr, msg);
+ Module->OnMessageReceived(nullptr, msg);
}
void TModuleClientHandler::OnReply(TAutoPtr<TBusMessage> req, TAutoPtr<TBusMessage> resp) {
@@ -863,7 +863,7 @@ void TModuleClientHandler::OnMessageSentOneWay(TAutoPtr<TBusMessage> req) {
TJobRunner* job = GetJob(req.Get());
Y_ASSERT(job);
Y_ASSERT(job->Job->Message != req.Get());
- job->EnqueueAndSchedule(TJobResponseMessage(req.Release(), nullptr, MESSAGE_OK));
+ job->EnqueueAndSchedule(TJobResponseMessage(req.Release(), nullptr, MESSAGE_OK));
job->UnRef();
}
@@ -871,7 +871,7 @@ void TModuleClientHandler::OnError(TAutoPtr<TBusMessage> msg, EMessageStatus sta
TJobRunner* job = GetJob(msg.Get());
if (job) {
Y_ASSERT(job->Job->Message != msg.Get());
- job->EnqueueAndSchedule(TJobResponseMessage(msg.Release(), nullptr, status));
+ job->EnqueueAndSchedule(TJobResponseMessage(msg.Release(), nullptr, status));
job->UnRef();
}
}