library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

#include "debug_receiver_handler.h"
 
#include "debug_receiver_proto.h" 
 
#include <util/generic/cast.h>
#include <util/string/printf.h>
 
void TDebugReceiverHandler::OnError(TAutoPtr<NBus::TBusMessage>, NBus::EMessageStatus status) {
    Cerr << "error " << status << "\n"; 
} 
 
void TDebugReceiverHandler::OnMessage(NBus::TOnMessageContext& message) {
    TDebugReceiverMessage* typedMessage = VerifyDynamicCast<TDebugReceiverMessage*>(message.GetMessage()); 
    Cerr << "type=" << typedMessage->GetHeader()->Type 
         << " size=" << typedMessage->GetHeader()->Size
         << " flags=" << Sprintf("0x%04x", (int)typedMessage->GetHeader()->FlagsInternal)
         << "\n";
 
    message.ForgetRequest(); 
}