aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/www/www.cpp
diff options
context:
space:
mode:
authorsingle <single@yandex-team.ru>2022-02-10 16:50:29 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:29 +0300
commit8ae96df130bbede609c3504aa9af1bc6ff5361b3 (patch)
tree4751832974bd75ca721269aa54faa15d76032dfb /library/cpp/messagebus/www/www.cpp
parent5d4e7b7c923852e0f6398791ec98a60cf9faab46 (diff)
downloadydb-8ae96df130bbede609c3504aa9af1bc6ff5361b3.tar.gz
Restoring authorship annotation for <single@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/www/www.cpp')
-rw-r--r--library/cpp/messagebus/www/www.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/library/cpp/messagebus/www/www.cpp b/library/cpp/messagebus/www/www.cpp
index 62ec241d85..e501cbf4a9 100644
--- a/library/cpp/messagebus/www/www.cpp
+++ b/library/cpp/messagebus/www/www.cpp
@@ -200,12 +200,12 @@ struct TBusWww::TImpl {
Queues.Add(s->GetQueue());
}
- void RegisterQueue(TBusMessageQueuePtr q) {
+ void RegisterQueue(TBusMessageQueuePtr q) {
Y_VERIFY(!!q);
- TGuard<TMutex> g(Mutex);
- Queues.Add(q);
- }
-
+ TGuard<TMutex> g(Mutex);
+ Queues.Add(q);
+ }
+
void RegisterModule(TBusModule* module) {
Y_VERIFY(!!module);
TGuard<TMutex> g(Mutex);
@@ -824,10 +824,10 @@ void TBusWww::RegisterServerSession(TBusServerSessionPtr s) {
Impl->RegisterServerSession(s);
}
-void TBusWww::RegisterQueue(TBusMessageQueuePtr q) {
- Impl->RegisterQueue(q);
-}
-
+void TBusWww::RegisterQueue(TBusMessageQueuePtr q) {
+ Impl->RegisterQueue(q);
+}
+
void TBusWww::RegisterModule(TBusModule* module) {
Impl->RegisterModule(module);
}