Class MessageFlow

• Defined in File message-flow.h

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)