diff --git a/libbroker/broker/internal/core_actor.cc b/libbroker/broker/internal/core_actor.cc index f10520e6..41b37cf7 100644 --- 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());