Method cache_event_payload

implementation/routing/src/routing_manager_client.cpp:1825–1847

}

void routing_manager_client::cache_event_payload(const std::shared_ptr<message>& _message) {
    const service_t its_service(_message->get_service());
    const instance_t its_instance(_message->get_instance());
    const method_t its_method(_message->get_method());

    std::scoped_lock its_lock(consumer_mutex_);
    auto its_event = find_consumed_event(its_service, its_instance, its_method, its_lock);
    if (!its_event) {
        // we received an event which was not yet requested.
        // create a placeholder until someone requests this event with
        // full information like eventgroup, field or not etc.
        std::set<eventgroup_t> its_eventgroups;
        register_consumer_event(host_->get_client(), its_service, its_instance, its_method, its_eventgroups, event_type_e::ET_UNKNOWN,
                                reliability_type_e::RT_UNKNOWN, std::chrono::milliseconds::zero(), false, true, nullptr, true, its_lock);
        its_event = find_consumed_event(its_service, its_instance, its_method, its_lock);
    }
    if (its_event) {
        if (its_event->is_field() || its_event->get_type() == event_type_e::ET_UNKNOWN) {
            its_event->prepare_update_payload(_message->get_payload(), true);
            its_event->update_payload();
        }
    }
}

void routing_manager_client::on_stop_offer_service(service_t _service, instance_t _instance, major_version_t _major, minor_version_t _minor,
                                                   [[maybe_unused]] std::scoped_lock<std::mutex> const& _consumer_lock) {