From 178f6bdac97b57300bbe0956633cf686a7e3ccee Mon Sep 17 00:00:00 2001 From: Yuval Lifshitz 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 --- 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