Restoring authorship annotation for <nga@yandex-team.ru>. Commit 2 of 2.

1 files changed, 37 insertions, 37 deletions

diff --git a/library/cpp/messagebus/test/helper/example_module.cpp b/library/cpp/messagebus/test/helper/example_module.cpp
index c907825924..65ecfcf73f 100644
--- a/library/cpp/messagebus/test/helper/example_module.cpp
+++ b/library/cpp/messagebus/test/helper/example_module.cpp
@@ -1,43 +1,43 @@
-#include "example_module.h" 
- 
-using namespace NBus; 
-using namespace NBus::NTest; 
- 
-TExampleModule::TExampleModule() 
-    : TBusModule("TExampleModule") 
-{ 
-    TBusQueueConfig queueConfig; 
-    queueConfig.NumWorkers = 5; 
-    Queue = CreateMessageQueue(queueConfig); 
-} 
- 
-void TExampleModule::StartModule() { 
-    CreatePrivateSessions(Queue.Get()); 
-    StartInput(); 
-} 
- 
-bool TExampleModule::Shutdown() { 
-    TBusModule::Shutdown(); 
-    return true; 
-} 
- 
-TBusServerSessionPtr TExampleModule::CreateExtSession(TBusMessageQueue&) { 
+#include "example_module.h"
+
+using namespace NBus;
+using namespace NBus::NTest;
+
+TExampleModule::TExampleModule()
+    : TBusModule("TExampleModule")
+{
+    TBusQueueConfig queueConfig;
+    queueConfig.NumWorkers = 5;
+    Queue = CreateMessageQueue(queueConfig);
+}
+
+void TExampleModule::StartModule() {
+    CreatePrivateSessions(Queue.Get());
+    StartInput();
+}
+
+bool TExampleModule::Shutdown() {
+    TBusModule::Shutdown();
+    return true;
+}
+
+TBusServerSessionPtr TExampleModule::CreateExtSession(TBusMessageQueue&) {
     return nullptr;
-} 
- 
-TBusServerSessionPtr TExampleServerModule::CreateExtSession(TBusMessageQueue& queue) { 
-    TBusServerSessionPtr r = CreateDefaultDestination(queue, &Proto, TBusServerSessionConfig()); 
-    ServerAddr = TNetAddr("localhost", r->GetActualListenPort()); 
-    return r; 
-} 
- 
+}
+
+TBusServerSessionPtr TExampleServerModule::CreateExtSession(TBusMessageQueue& queue) {
+    TBusServerSessionPtr r = CreateDefaultDestination(queue, &Proto, TBusServerSessionConfig());
+    ServerAddr = TNetAddr("localhost", r->GetActualListenPort());
+    return r;
+}
+
 TExampleClientModule::TExampleClientModule()
     : Source()
 {
 }
- 
-TBusServerSessionPtr TExampleClientModule::CreateExtSession(TBusMessageQueue& queue) { 
-    Source = CreateDefaultSource(queue, &Proto, TBusServerSessionConfig()); 
-    Source->RegisterService("localhost"); 
+
+TBusServerSessionPtr TExampleClientModule::CreateExtSession(TBusMessageQueue& queue) {
+    Source = CreateDefaultSource(queue, &Proto, TBusServerSessionConfig());
+    Source->RegisterService("localhost");
     return nullptr;
-} 
+}