MQTTClient Class

(MQTTIO::MQTTClient)
Inherits: IOServer, OSAPIThread, and

Public Functions

Reimplemented Public Functions

virtual void Activate() override
virtual void Create(const char *fullName) override
virtual void Destroy() override
virtual int GetDebugLevel() override
virtual void Suspend() override

Protected Functions

void ConnectBroker(bool async)
bool ConnectionParamsChanged()
std::string GenerateClientID(const char *baseString)
void PublishLWTOnConnect()
void PublishLWTOnDisconnect()
void SetConnected(bool newStatus)
void WaitForReconnectTimeoutOrStop()
void on_connect(int rc) override
void on_disconnect(int rc) override
void on_publish(int) override
void on_subscribe(int, int, const int *) override
void on_unsubscribe(int) override

Reimplemented Protected Functions

virtual void Configure(const char *xml) override
virtual void FillNodeChildren(CDP::StudioAPI::NodeStream &stream) const override
virtual std::string GetNodeTypeName() const override
virtual bool HandleXMLElement(XMLElementEx *XMLel) override
virtual bool IsCommProblem() override
virtual void Main() override
virtual void ProcessOffline() override
virtual void ProcessOnline() override
virtual void SetPropertyHandler(CDPPropertyBase *pProp) override

Additional Inherited Members

Member Function Documentation

MQTTClient::MQTTClient()

Default constructs an instance of MQTTClient.

MQTTClient::~MQTTClient()

Destroys the instance of MQTTClient.

[override virtual] void MQTTClient::Activate()

[override virtual protected] void MQTTClient::Configure(const char *xml)

[protected] void MQTTClient::ConnectBroker(bool async)

[protected] bool MQTTClient::ConnectionParamsChanged()

[override virtual] void MQTTClient::Create(const char *fullName)

[override virtual] void MQTTClient::Destroy()

[override virtual protected] void MQTTClient::FillNodeChildren(CDP::StudioAPI::NodeStream &stream) const

[protected] std::string MQTTClient::GenerateClientID(const char *baseString)

[override virtual] int MQTTClient::GetDebugLevel()

[override virtual protected] std::string MQTTClient::GetNodeTypeName() const

[override virtual protected] bool MQTTClient::HandleXMLElement(XMLElementEx *XMLel)

void MQTTClient::IncreasePublishedCount()

void MQTTClient::IncreaseSubscribedCount()

[override virtual protected] bool MQTTClient::IsCommProblem()

[override virtual protected] void MQTTClient::Main()

[override virtual protected] void MQTTClient::ProcessOffline()

[override virtual protected] void MQTTClient::ProcessOnline()

[protected] void MQTTClient::PublishLWTOnConnect()

[protected] void MQTTClient::PublishLWTOnDisconnect()

[protected] void MQTTClient::SetConnected(bool newStatus)

void MQTTClient::SetLastMessageTimestamp()

[override virtual protected] void MQTTClient::SetPropertyHandler(CDPPropertyBase *pProp)

[override virtual] void MQTTClient::Suspend()

void MQTTClient::UngracefullyCloseConnection()

[protected] void MQTTClient::WaitForReconnectTimeoutOrStop()

[protected] void MQTTClient::on_connect(int rc)

[protected] void MQTTClient::on_disconnect(int rc)

[protected] void MQTTClient::on_publish(int)

[protected] void MQTTClient::on_subscribe(int, int, const int *)

[protected] void MQTTClient::on_unsubscribe(int)