Restoring authorship annotation for <nga@yandex-team.ru>. Commit 1 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 65ecfcf73f..c907825924 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;
-}
+}