diff --git a/src/broker/Manager.cc b/src/broker/Manager.cc index b5407d413a..b2443efb0e 100644 --- a/src/broker/Manager.cc +++ b/src/broker/Manager.cc @@ -3,6 +3,8 @@ #include #include #include +#include +#include #include #include #include @@ -112,6 +114,11 @@ void print_escaped(std::string& buf, std::string_view str) { buf.push_back('"'); } +class LoggerAdapter : public broker::event_observer { +public: + explicit LoggerAdapter() {} +}; + } // namespace namespace zeek::Broker { @@ -361,6 +368,9 @@ void Manager::InitPostScript() { config.set("caf.work-stealing.moderate-steal-interval", get_option("Broker::moderate_interval")->AsCount()); config.set("caf.work-stealing.relaxed-steal-interval", get_option("Broker::relaxed_interval")->AsCount()); + auto adapter = std::make_shared(); + broker::logger(adapter); // *must* be called before creating the BrokerState + auto cqs = get_option("Broker::congestion_queue_size")->AsCount(); bstate = std::make_shared(std::move(config), cqs);