aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/test/example
diff options
context:
space:
mode:
authoragorodilov <agorodilov@yandex-team.ru>2022-02-10 16:47:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:09 +0300
commitbd5ef432f5cfb1e18851381329d94665a4c22470 (patch)
treeb83306b6e37edeea782e9eed673d89286c4fef35 /library/cpp/messagebus/test/example
parent7a4979e6211c3e78c7f9041d4a9e5d3405343c36 (diff)
downloadydb-bd5ef432f5cfb1e18851381329d94665a4c22470.tar.gz
Restoring authorship annotation for <agorodilov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/test/example')
-rw-r--r--library/cpp/messagebus/test/example/client/client.cpp6
-rw-r--r--library/cpp/messagebus/test/example/server/server.cpp4
2 files changed, 5 insertions, 5 deletions
diff --git a/library/cpp/messagebus/test/example/client/client.cpp b/library/cpp/messagebus/test/example/client/client.cpp
index b61bfb1a6ee..89b5f2c9beb 100644
--- a/library/cpp/messagebus/test/example/client/client.cpp
+++ b/library/cpp/messagebus/test/example/client/client.cpp
@@ -18,11 +18,11 @@ namespace NCalculator {
ClientSession = TBusClientSession::Create(&Proto, this, config, MessageQueue);
}
- ~TCalculatorClient() override {
+ ~TCalculatorClient() override {
MessageQueue->Stop();
}
- void OnReply(TAutoPtr<TBusMessage> request, TAutoPtr<TBusMessage> response0) override {
+ void OnReply(TAutoPtr<TBusMessage> request, TAutoPtr<TBusMessage> response0) override {
Y_VERIFY(response0->GetHeader()->Type == TResponse::MessageType, "wrong response");
TResponse* response = VerifyDynamicCast<TResponse*>(response0.Get());
if (request->GetHeader()->Type == TRequestSum::MessageType) {
@@ -40,7 +40,7 @@ namespace NCalculator {
}
}
- void OnError(TAutoPtr<TBusMessage>, EMessageStatus status) override {
+ void OnError(TAutoPtr<TBusMessage>, EMessageStatus status) override {
Cerr << "got error " << status << "\n";
}
};
diff --git a/library/cpp/messagebus/test/example/server/server.cpp b/library/cpp/messagebus/test/example/server/server.cpp
index b7e1045782c..13e52d75f58 100644
--- a/library/cpp/messagebus/test/example/server/server.cpp
+++ b/library/cpp/messagebus/test/example/server/server.cpp
@@ -15,11 +15,11 @@ namespace NCalculator {
ServerSession = TBusServerSession::Create(&Proto, this, config, MessageQueue);
}
- ~TCalculatorServer() override {
+ ~TCalculatorServer() override {
MessageQueue->Stop();
}
- void OnMessage(TOnMessageContext& request) override {
+ void OnMessage(TOnMessageContext& request) override {
if (request.GetMessage()->GetHeader()->Type == TRequestSum::MessageType) {
TRequestSum* requestSum = VerifyDynamicCast<TRequestSum*>(request.GetMessage());
int a = requestSum->Record.GetA();