std::vector< std::shared_ptr< const MqttExternalMessage > > topics_
void handle_mqtt_msg(mqtt::const_message_ptr msg)
Message received from mqtt.
void register_sockets(zmqpp::reactor *reactor)
zmqpp::socket bus_push_
Socket to write to the message bus.
std::shared_ptr< const MqttServerConfig > config_
std::shared_ptr< mqtt::async_client > client_
The MQTT client.
Implementation class, for use by the Mqtt module only.
const std::string & name() const
const std::vector< std::shared_ptr< const MqttExternalMessage > > & topics() const
void handle_topic_request(const std::string &topic_name)
Request received on the topic specific socket.
std::map< std::string, zmqpp::socket > topic_socks_
REP socket to receive command on for topics.
std::shared_ptr< const MqttServerConfig > config() const
MqttExternalServer(zmqpp::context &ctx, std::shared_ptr< const MqttServerConfig > config, const std::vector< std::shared_ptr< const MqttExternalMessage >> &topics)
zmqpp::socket sock_
REP socket to receive command on.