diff --git a/src/cluster/backend/zeromq/ZeroMQ.cc b/src/cluster/backend/zeromq/ZeroMQ.cc index 99207e82f5..2b739c905b 100644 --- a/src/cluster/backend/zeromq/ZeroMQ.cc +++ b/src/cluster/backend/zeromq/ZeroMQ.cc @@ -77,8 +77,6 @@ ZeroMQBackend::~ZeroMQBackend() { } void ZeroMQBackend::DoInitPostScript() { - ThreadedBackend::DoInitPostScript(); - listen_xpub_endpoint = zeek::id::find_val("Cluster::Backend::ZeroMQ::listen_xpub_endpoint")->ToStdString(); listen_xsub_endpoint = @@ -98,8 +96,8 @@ void ZeroMQBackend::DoInitPostScript() { event_subscription = zeek::event_registry->Register("Cluster::Backend::ZeroMQ::subscription"); } - void ZeroMQBackend::DoTerminate() { + ThreadedBackend::DoTerminate(); ZEROMQ_DEBUG("Shutting down ctx"); ctx.shutdown(); ZEROMQ_DEBUG("Joining self_thread"); diff --git a/src/cluster/backend/zeromq/ZeroMQ.h b/src/cluster/backend/zeromq/ZeroMQ.h index 3a6783ff5c..ab33917cb0 100644 --- a/src/cluster/backend/zeromq/ZeroMQ.h +++ b/src/cluster/backend/zeromq/ZeroMQ.h @@ -62,8 +62,6 @@ private: bool DoPublishLogWrites(const logging::detail::LogWriteHeader& header, const std::string& format, cluster::detail::byte_buffer& buf) override; - const char* Tag() override { return "ZeroMQ"; } - bool DoProcessBackendMessage(int tag, detail::byte_buffer_span payload) override; // Script level variables.