Class PubSubHandler#

Defined in File common.h

Class Documentation#

class PubSubHandler#

Public Static Functions

template<typename Interface> static inline long init_pubsub(zmqpp::context &context, Interface &iface, const std::initializer_list<std::string> &topics = {})#

initialize publisher, subscriber, and start subscriber thread

Returns:: ERROR | NO_ERROR

template<typename Interface> static inline void start_subscriber_thread(Interface &iface)#: starts subscriber thread if needed

template<typename Interface> static inline void subscriber_thread(Interface &iface)#: the actual subscriber thread

template<typename Interface> static inline void stop_subscriber_thread(Interface &iface)#: stop the subscriber thread

template<typename Interface> static inline long process_incoming_message(Interface &iface, std::string topic, std::string message_in)#

processes incoming subscribed telemetry messages

Parameters:: message_in – [in] incoming message, expects serialized JSON string
Returns:: ERROR | NO_ERROR