diff options
author | yuryalekseev <yuryalekseev@yandex-team.ru> | 2022-02-10 16:50:33 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:33 +0300 |
commit | 37b41bf0956ce3c4d47e240dc8fc6b5a2e4638c0 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library | |
parent | dde1573d56354127a7cb8b3461dd08bcdd48a045 (diff) | |
download | ydb-37b41bf0956ce3c4d47e240dc8fc6b5a2e4638c0.tar.gz |
Restoring authorship annotation for <yuryalekseev@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library')
-rw-r--r-- | library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp | 8 | ||||
-rw-r--r-- | library/cpp/messagebus/rain_check/messagebus/messagebus_client.h | 6 |
2 files changed, 7 insertions, 7 deletions
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp index 6d9cdf3800..daac8d9a99 100644 --- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp +++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp @@ -49,10 +49,10 @@ void TBusClientService::SendOneWay( ProcessResultCommon(message, addr, future, ok); } -NBus::TBusClientSessionPtr TBusClientService::GetSessionForMonitoring() const { - return Session; -} - +NBus::TBusClientSessionPtr TBusClientService::GetSessionForMonitoring() const { + return Session; +} + void TBusClientService::Send( TBusMessageAutoPtr message, const TNetAddr& addr, TBusFuture* future) { diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h index c43e54161a..0a291cdea6 100644 --- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h +++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h @@ -52,9 +52,9 @@ namespace NRainCheck { void Send(NBus::TBusMessageAutoPtr, const NBus::TNetAddr&, TBusFuture* future); void SendOneWay(NBus::TBusMessageAutoPtr, const NBus::TNetAddr&, TBusFuture* future); - // Use it only for monitoring - NBus::TBusClientSessionPtr GetSessionForMonitoring() const; - + // Use it only for monitoring + NBus::TBusClientSessionPtr GetSessionForMonitoring() const; + private: void SendCommon(NBus::TBusMessage*, const NBus::TNetAddr&, TBusFuture* future); void ProcessResultCommon(NBus::TBusMessageAutoPtr, const NBus::TNetAddr&, TBusFuture* future, NBus::EMessageStatus); |