From 178f6bdac97b57300bbe0956633cf686a7e3ccee Mon Sep 17 00:00:00 2001

From: Yuval Lifshitz <ylifshit@redhat.com>

Date: Fri, 12 Mar 2021 08:56:45 +0200

Subject: [PATCH] librgw/notifications: initialize kafka and amqp

Fixes: https://tracker.ceph.com/issues/49738

Signed-off-by: Yuval Lifshitz <ylifshit@redhat.com>

---

 src/rgw/librgw.cc | 23 +++++++++++++++++++++++

 1 file changed, 23 insertions(+)

diff --git a/src/rgw/librgw.cc b/src/rgw/librgw.cc

index 012cc54c3b..a5351dbe7c 100644

--- a/src/rgw/librgw.cc

+++ b/src/rgw/librgw.cc

@@ -53,6 +53,12 @@

 #include "rgw_http_client.h"

 #include "rgw_http_client_curl.h"

 #include "rgw_perf_counters.h"

+#ifdef WITH_RADOSGW_AMQP_ENDPOINT

+#include "rgw_amqp.h"

+#endif

+#ifdef WITH_RADOSGW_KAFKA_ENDPOINT

+#include "rgw_kafka.h"

+#endif

 #include "services/svc_zone.h"

@@ -617,6 +623,17 @@ namespace rgw {

       /* ignore error */

     }

+#ifdef WITH_RADOSGW_AMQP_ENDPOINT

+    if (!rgw::amqp::init(cct.get())) {

+      derr << "ERROR: failed to initialize AMQP manager" << dendl;

+    }

+#endif

+#ifdef WITH_RADOSGW_KAFKA_ENDPOINT

+    if (!rgw::kafka::init(cct.get())) {

+      derr << "ERROR: failed to initialize Kafka manager" << dendl;

+    }

+#endif

+

     return 0;

   } /* RGWLib::init() */

@@ -645,6 +662,12 @@ namespace rgw {

     rgw_shutdown_resolver();

     rgw_http_client_cleanup();

     rgw::curl::cleanup_curl();

+#ifdef WITH_RADOSGW_AMQP_ENDPOINT

+    rgw::amqp::shutdown();

+#endif

+#ifdef WITH_RADOSGW_KAFKA_ENDPOINT

+    rgw::kafka::shutdown();

+#endif

     rgw_perf_stop(g_ceph_context);

-- 

2.26.2