Restoring authorship annotation for <[email protected]>. Commit 2 of 2.

1 files changed, 25 insertions, 25 deletions

diff --git a/library/cpp/messagebus/messqueue.cpp b/library/cpp/messagebus/messqueue.cpp
index c956d4a4732..3474d62705f 100644
--- a/library/cpp/messagebus/messqueue.cpp
+++ b/library/cpp/messagebus/messqueue.cpp
@@ -131,34 +131,34 @@ TBusClientSessionPtr TBusMessageQueue::CreateSource(TBusProtocol* proto, IBusCli
 }
 
 TBusServerSessionPtr TBusMessageQueue::CreateDestination(TBusProtocol* proto, IBusServerHandler* handler, const TBusClientSessionConfig& config, const TString& name) {
-    TRemoteServerSessionPtr session(new TRemoteServerSession(this, proto, handler, config, name)); 
-    try { 
-        int port = config.ListenPort; 
-        if (port == 0) { 
-            port = Locator->GetLocalPort(proto->GetService()); 
-        } 
-        if (port == 0) { 
-            port = proto->GetPort(); 
-        } 
-
-        session->Listen(port, this); 
- 
-        Add(session.Get()); 
-        return session.Release(); 
-    } catch (...) { 
-        Y_FAIL("create destination failure: %s", CurrentExceptionMessage().c_str()); 
-    } 
+    TRemoteServerSessionPtr session(new TRemoteServerSession(this, proto, handler, config, name));
+    try {
+        int port = config.ListenPort;
+        if (port == 0) {
+            port = Locator->GetLocalPort(proto->GetService());
+        }
+        if (port == 0) {
+            port = proto->GetPort();
+        }
+
+        session->Listen(port, this);
+
+        Add(session.Get());
+        return session.Release();
+    } catch (...) {
+        Y_FAIL("create destination failure: %s", CurrentExceptionMessage().c_str());
+    }
 }
 
 TBusServerSessionPtr TBusMessageQueue::CreateDestination(TBusProtocol* proto, IBusServerHandler* handler, const TBusServerSessionConfig& config, const TVector<TBindResult>& bindTo, const TString& name) {
-    TRemoteServerSessionPtr session(new TRemoteServerSession(this, proto, handler, config, name)); 
-    try { 
-        session->Listen(bindTo, this); 
-        Add(session.Get()); 
-        return session.Release(); 
-    } catch (...) { 
-        Y_FAIL("create destination failure: %s", CurrentExceptionMessage().c_str()); 
-    } 
+    TRemoteServerSessionPtr session(new TRemoteServerSession(this, proto, handler, config, name));
+    try {
+        session->Listen(bindTo, this);
+        Add(session.Get());
+        return session.Release();
+    } catch (...) {
+        Y_FAIL("create destination failure: %s", CurrentExceptionMessage().c_str());
+    }
 }
 
 void TBusMessageQueue::Add(TIntrusivePtr<TBusSessionImpl> session) {