Class TransportRegistry

Class Documentation

class TransportRegistry

Registry of transport providers keyed by protocol name.

Public Functions

void register_transport(std::unique_ptr<SubscriptionTransportProvider> provider)
SubscriptionTransportProvider *get_transport(const std::string &protocol) const
bool has_transport(const std::string &protocol) const
void shutdown_all(SubscriptionManager &sub_mgr)

Shutdown all subscriptions by delegating to SubscriptionManager::shutdown(). Transport cleanup happens via the manager’s on_removed callback, which calls SubscriptionTransportProvider::stop() for each active subscription.