intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 46 insertions, 0 deletions

diff --git a/library/cpp/monlib/messagebus/mon_messagebus.h b/library/cpp/monlib/messagebus/mon_messagebus.h
new file mode 100644
index 0000000000..e1fa73c69f
--- /dev/null
+++ b/library/cpp/monlib/messagebus/mon_messagebus.h
@@ -0,0 +1,46 @@
+#pragma once
+
+#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/www/www.h>
+
+#include <library/cpp/monlib/service/pages/mon_page.h>
+
+namespace NMonitoring {
+    template <class TBusSmth>
+    class TBusSmthMonPage: public NMonitoring::IMonPage {
+    private:
+        TBusSmth* Smth;
+
+    public:
+        explicit TBusSmthMonPage(const TString& name, const TString& title, TBusSmth* smth)
+            : IMonPage("msgbus/" + name, title)
+            , Smth(smth)
+        {
+        }
+        void Output(NMonitoring::IMonHttpRequest& request) override {
+            Y_UNUSED(request);
+            request.Output() << NMonitoring::HTTPOKHTML;
+            request.Output() << "<h2>" << Title << "</h2>";
+            request.Output() << "<pre>";
+            request.Output() << Smth->GetStatus();
+            request.Output() << "</pre>";
+        }
+    };
+
+    using TBusQueueMonPage = TBusSmthMonPage<NBus::TBusMessageQueue>;
+    using TBusModuleMonPage = TBusSmthMonPage<NBus::TBusModule>;
+
+    class TBusNgMonPage: public NMonitoring::IMonPage {
+    public:
+        TIntrusivePtr<NBus::TBusWww> BusWww;
+
+    public:
+        TBusNgMonPage()
+            : IMonPage("messagebus", "MessageBus")
+            , BusWww(new NBus::TBusWww)
+        {
+        }
+        void Output(NMonitoring::IMonHttpRequest& request) override;
+    };
+
+}