aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/message_status.h12
-rw-r--r--library/cpp/messagebus/remote_connection.cpp4
2 files changed, 8 insertions, 8 deletions
diff --git a/library/cpp/messagebus/message_status.h b/library/cpp/messagebus/message_status.h
index be274d4252..e1878960b3 100644
--- a/library/cpp/messagebus/message_status.h
+++ b/library/cpp/messagebus/message_status.h
@@ -43,15 +43,15 @@ namespace NBus {
// For lwtrace
struct TMessageStatusField {
typedef int TStoreType;
- typedef int TFuncParam;
-
+ typedef int TFuncParam;
+
static void ToString(int value, TString* out) {
*out = GetMessageStatus((NBus::EMessageStatus)value);
}
-
- static int ToStoreType(int value) {
- return value;
- }
+
+ static int ToStoreType(int value) {
+ return value;
+ }
};
} // ns
diff --git a/library/cpp/messagebus/remote_connection.cpp b/library/cpp/messagebus/remote_connection.cpp
index 283b277d7b..22932569db 100644
--- a/library/cpp/messagebus/remote_connection.cpp
+++ b/library/cpp/messagebus/remote_connection.cpp
@@ -67,7 +67,7 @@ namespace NBus {
}
TRemoteConnection::TWriterData::~TWriterData() {
- Y_VERIFY(AtomicGet(Down));
+ Y_VERIFY(AtomicGet(Down));
Y_VERIFY(SendQueue.Empty());
}
@@ -119,7 +119,7 @@ namespace NBus {
}
TRemoteConnection::TReaderData::~TReaderData() {
- Y_VERIFY(AtomicGet(Down));
+ Y_VERIFY(AtomicGet(Down));
}
void TRemoteConnection::Send(TNonDestroyingAutoPtr<TBusMessage> msg) {