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
>
voidregisterSubscriber
(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)¶
-