Class MessageFlow

Class Documentation

class message_flow::MessageFlow

Public Functions

~MessageFlow()
template<typename MessageTopicDefinition>
PublisherFunction<MessageTopicDefinition> registerPublisher()
template<typename MessageTopicDefinition>
void registerSubscriber(const std::string &subscriber_node_name, const DeliveryOptions &delivery_options, const SubscriberCallback<MessageTopicDefinition> &callback)
void shutdown()
void waitUntilIdle() const
std::string printDeliveryQueueStatistics() const

Public Static Functions

template<typename MessageDispatcherType>
static inline MessageFlow *create(size_t num_threads)

Protected Functions

explicit MessageFlow(const MessageDispatcherPtr &dispatcher)