intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 23 insertions, 0 deletions

diff --git a/library/cpp/messagebus/handler_impl.h b/library/cpp/messagebus/handler_impl.h
new file mode 100644
index 0000000000..6593f04cc3
--- /dev/null
+++ b/library/cpp/messagebus/handler_impl.h
@@ -0,0 +1,23 @@
+#pragma once
+
+#include "handler.h"
+#include "local_flags.h"
+#include "session.h"
+
+namespace NBus {
+    template <typename U /* <: TBusMessage */>
+    EMessageStatus TOnMessageContext::SendReplyAutoPtr(TAutoPtr<U>& response) {
+        return Session->SendReplyAutoPtr(Ident, response);
+    }
+
+    inline EMessageStatus TOnMessageContext::SendReplyMove(TBusMessageAutoPtr response) {
+        return SendReplyAutoPtr(response);
+    }
+
+    inline void TOnMessageContext::AckMessage(TBusIdentity& ident) {
+        Y_VERIFY(Ident.LocalFlags == NPrivate::MESSAGE_IN_WORK);
+        Y_VERIFY(ident.LocalFlags == 0);
+        Ident.Swap(ident);
+    }
+
+}