diff --git a/src/cluster/Backend.cc b/src/cluster/Backend.cc index 59e19f7ae0..675fcd7982 100644 --- a/src/cluster/Backend.cc +++ b/src/cluster/Backend.cc @@ -213,11 +213,6 @@ void ThreadedBackend::QueueForProcessing(QueueMessage&& qmessages) { onloop->QueueForProcessing(std::move(qmessages)); } -void ThreadedBackend::Process() { - if ( onloop ) - onloop->Process(); -} - void ThreadedBackend::Process(QueueMessage&& msg) { // sonarlint wants to use std::visit. not sure... if ( auto* emsg = std::get_if(&msg) ) { diff --git a/src/cluster/Backend.h b/src/cluster/Backend.h index ba689be8d3..8c40e29703 100644 --- a/src/cluster/Backend.h +++ b/src/cluster/Backend.h @@ -570,12 +570,6 @@ protected: */ void QueueForProcessing(QueueMessage&& messages); - /** - * Delegate to onloop->Process() to trigger processing - * of outstanding queued messages explicitly, if any. - */ - void Process(); - /** * The default DoInit() implementation of ThreadedBackend * registers itself as a counting IO source to keep the IO