Fix log statement when disconnecting stalled peers

zeek · Dec 3, 2024 · f848eb4 · f848eb4
1 parent e295987
commit f848eb4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/libbroker/broker/internal/core_actor.cc b/libbroker/broker/internal/core_actor.cc
@@ -871,8 +871,8 @@ caf::error core_actor_state::init_new_peer(endpoint_id peer_id,
       })
       // Disconnect unresponsive peers.
       .on_backpressure_buffer(peer_buffer_size(), peer_overflow_policy())
-      .do_on_error([this, ptr](const caf::error& what) {
-        CAF_LOG_INFO("remove peer" << peer_id << "due to:" << what);
+      .do_on_error([this, ptr, peer_id](const caf::error& what) {
+        BROKER_INFO("remove peer" << peer_id << "due to:" << what);
         ptr->force_disconnect();
       })
       .as_observable());