Method find_consumed_events

implementation/routing/src/routing_manager_client.cpp:2890–2902

}

std::set<std::shared_ptr<event>> routing_manager_client::find_consumed_events(service_t _service, instance_t _instance,
                                                                              eventgroup_t _eventgroup) const {
    std::scoped_lock its_lock(consumer_mutex_);
    const auto search = consumed_eventgroups_.find(service_instance_t{_service, _instance});
    if (search != consumed_eventgroups_.end()) {
        const auto found_eventgroup = search->second.find(_eventgroup);
        if (found_eventgroup != search->second.end()) {
            return found_eventgroup->second->get_events();
        }
    }

    return std::set<std::shared_ptr<event>>();
}

void routing_manager_client::unsubscribe_base(client_t _client, service_t _service, instance_t _instance, eventgroup_t _eventgroup,
                                              event_t _event, std::scoped_lock<std::mutex> const& _lock) {