diff options
Diffstat (limited to 'library/cpp/messagebus/debug_receiver/debug_receiver_proto.h')
-rw-r--r-- | library/cpp/messagebus/debug_receiver/debug_receiver_proto.h | 27 |
1 files changed, 27 insertions, 0 deletions
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h new file mode 100644 index 0000000000..d34710dcf7 --- /dev/null +++ b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h @@ -0,0 +1,27 @@ +#pragma once + +#include <library/cpp/messagebus/ybus.h> + +struct TDebugReceiverMessage: public NBus::TBusMessage { + /// constructor to create messages on sending end + TDebugReceiverMessage(ui16 type) + : NBus::TBusMessage(type) + { + } + + /// constructor with serialzed data to examine the header + TDebugReceiverMessage(NBus::ECreateUninitialized) + : NBus::TBusMessage(NBus::ECreateUninitialized()) + { + } + + TBuffer Payload; +}; + +struct TDebugReceiverProtocol: public NBus::TBusProtocol { + TDebugReceiverProtocol(); + + void Serialize(const NBus::TBusMessage* mess, TBuffer& data) override; + + TAutoPtr<NBus::TBusMessage> Deserialize(ui16 messageType, TArrayRef<const char> payload) override; +}; |