#include <MosquittoClient.h>

Inheritance diagram for BeeeOn::MosquittoClient:

Public Types
typedef Poco::SharedPtr < MosquittoClient >	Ptr

Public Types inherited from BeeeOn::StoppableRunnable
typedef Poco::SharedPtr < StoppableRunnable >	Ptr

Public Types inherited from BeeeOn::MqttClient
typedef Poco::SharedPtr < MqttClient >	Ptr

Public Member Functions
void	run () override

void	stop () override

void	setHost (const std::string &host)

void	setPort (int port)

void	setSubTopics (const std::list< std::string > &subTopics)

void	setReconnectTimeout (const Poco::Timespan &timeout)

void	setClientID (const std::string &id)

std::string	clientID () const

void	publish (const MqttMessage &msq) override

MqttMessage	receive (const Poco::Timespan &timeout) override

Protected Member Functions
virtual std::string	buildClientID () const

void	connect ()

Detailed Description

Mosquitto client runs in a thread. Before its run it is necessary to set following parameters:

host: default localhost
port: default 1883
reconnect wait timeout: 5 s
client id: default - empty

Member Function Documentation

void MosquittoClient::connect ( )

protected

Non-blocking connection to broker request. After set client name must be call MosquittoClient::connect();

void MosquittoClient::publish ( const MqttMessage & msq )

overridevirtual

Publish a message on a given topic.

Implements BeeeOn::MqttClient.

MqttMessage MosquittoClient::receive ( const Poco::Timespan & timeout )

overridevirtual

Waiting for a new message according to given timeout. Returns message, if some message is in queue, otherwise waiting for a new message or timeout exception.

This method should not be called by multiple threads, received message could be given to only one thread.

Timeout: