Base class for easy MQTT Objects (MqttObj). mqtt_obj are comprised of higher order parent objects that contain registered child objects. More...

#include <mqtt.h>

Inherits MQTT::mqtt_leaf.

Inherited by ControlSet, PIDSet, and TempRange.

Public Member Functions
virtual ValueTestResult	TestOrSetValue (ParsedJsonDataSet &pjs, bool setVal) override
	whether the current index of a JSON dataset is valid for this object, or assign the value at the current index of the dataset to this object.

virtual int	RenderToBuffer (eObj_Serialize_t form, uint8_t *buf, int buflen) override
	Render this object to an output buffer.

virtual int	RenderToFd (eObj_Serialize_t form, int fd) override
	Render this object to an output socket.

Public Member Functions inherited from MQTT::mqtt_leaf
	~mqtt_leaf ()
	~mqtt_leaf Destructor for base mqtt_leaf

void	RemoveFromTree ()
	Remove this object from it's parent tree.

bool	NameMatch (const char *cp)
	Determine whether a given name matches this object.

virtual int	GetPubTopicName (NBString &s)
	Get the Topic Name this object Publishes to.

int	Publish (int waitForCompletion=-1)
	Publishes the current MQTT object, optionally waiting for completion.

void	SetPublishInterval (uint32_t intervalPeriodTicks)
	Sets or clears an automatic publishing interval for this MQTT object.

virtual void	SetSerializationForm (eObj_Serialize_t form)
	Set the default serialization format for this object.

eObj_Serialize_t	GetSerializationForm ()
	Get the default serialization format for this object.

virtual void	SetFlags (uint16_t newFlags)
	Set additional behavioral flags for this object.

virtual void	ClearFlags (uint16_t delFlags)
	Clear behavioral flags from this object.

uint16_t	GetFlags ()
	Get the behavioral flags set for this object.

int	getPriority ()
	Get the message priority for this object.

Protected Member Functions
	mqtt_obj (const char topic, Client mClient, uint16_t flags=(eObj_Flag_PubOnWrite\|eObj_Flag_Subscribe\|eObj_Flag_Sub_NoLocal))
	Constructor for a standalone mqtt_obj object.

	mqtt_obj (mqtt_leaf &parent, const char topic, Client mClient, uint16_t flags=(eObj_Flag_PubOnWrite\|eObj_Flag_Subscribe\|eObj_Flag_Sub_NoLocal))
	Constructor for an mqtt_obj with a known parent object.

	~mqtt_obj ()
	~mqtt_obj Destructor for base mqtt_obj

mqtt_leaf *	FindChild (const char *topic)
	the child object that is registered for the given Topic Name.

virtual mqtt_leaf *	GetChildren () override
	the first child of this object.

virtual mqtt_leaf *	AddChild (mqtt_leaf *child) override
	an MqttObj as a child to this object.

virtual mqtt_leaf *	RemoveFirstChild () override
	Remove the first child from this object.

virtual void	SetPubState (uint8_t newState) override
	the Publish state

virtual void	SetSubState (uint8_t newState) override
	the Subscribe state

virtual int	ParseFd (int mqttFd) override
	the data from a file descriptor according to this object's current default serialization method and assign the value.

virtual int	GetSubTopicFilter (NBString &s) override
	the Subscription Topic Filter this object Subscribes to.

virtual int	SubscribeEvent (int mqttFd, PacketInfo::Msg *msg) override
	Handle a message sent by the Broker triggered by this object's Subscription.

virtual int	GetRenderLength (eObj_Serialize_t form=eObj_Serialize_CURRENT_FORM) override
	the number of bytes used to serialize this object in a particular format.

Protected Member Functions inherited from MQTT::mqtt_leaf
	mqtt_leaf (const char topic, Client mClient, uint16_t flags=(eObj_Flag_PubOnWrite\|eObj_Flag_Subscribe\|eObj_Flag_Sub_NoLocal))
	Constructor for mqtt_leaf objects.

	mqtt_leaf (mqtt_leaf &parent, const char topic, Client mClient, uint16_t flags=(eObj_Flag_PubOnWrite\|eObj_Flag_Subscribe\|eObj_Flag_Sub_NoLocal))
	Constructor for mqtt_leaf objects.

void	ForEachLeaf (LeafCallBack p, void pd)
	Call a function on each element of the MqttObj tree with this object as the root.

void	RootParse (ParsedJsonDataSet &pjs)
	Assign to this object tree from a JSON dataset.

bool	MatchId (ParsedJsonDataSet &pjs)
	Determine whether the JSON dataset's current index matches this object's name.

int	QueuePublish ()
	Queue this object to be Published via the registered Client.

int	QueueSubscribe ()
	Queue this object to be Subscribed via the registered Client.

int	QueueUnsubscribe ()
	Queue this object to be Unsubscribed via the registered Client.

int	Assign ()
	Perform post assignemnt operations.

uint8_t	PubState ()
	Get the Publish state.

uint8_t	SubState ()
	Get the Subscribe state of this object.

int	HandleSubAck (int mqttFd, PacketInfo::Msg *msg)
	Handle a Subscribe Acknowledge message from the broker for our Subscribe request.

int	HandleUnsubAck (int mqttFd, PacketInfo::Msg *msg)
	Handle an Unsubscribe Acknowledge message from the broker for our Unsubscribe request.

int	HandlePubAck (int mqttFd, PacketInfo::Msg *msg)
	Handle an Publish Acknowledge message from the broker for our Publish request.

Additional Inherited Members
Public Types inherited from MQTT::mqtt_leaf
enum	eObj_State_t
	Mqtt Object Publication/Subscription States.

Static Public Member Functions inherited from MQTT::mqtt_leaf
static int	MqttRxPublish (Client mClient, int mqttFd, PacketInfo::Msg msg, void *ctx)
	Static message handler for Publish messages received by the registered Client.

Protected Attributes inherited from MQTT::mqtt_leaf
NBInterpolatedString	topicName
	Topic name or additional branch.

eObj_Serialize_t	publishForm
	Default serialization form.

uint16_t	mFlags
	Behavioral flags.

Detailed Description

Base class for easy MQTT Objects (MqttObj). mqtt_obj are comprised of higher order parent objects that contain registered child objects.

Constructor & Destructor Documentation

◆ mqtt_obj() [1/2]

MQTT::mqtt_obj::mqtt_obj	(	const char *	topic,
		Client *	mClient,
		uint16_t	flags = (eObj_Flag_PubOnWrite\|eObj_Flag_Subscribe\|eObj_Flag_Sub_NoLocal) )

protected

Constructor for a standalone mqtt_obj object.

Parameters

*topic	Mqtt Topic Name to use for Publish/Subcribe.
*mClient	Pointer to Client to register with. If NULL, it will be registered with the first created Client.
flags	Behavioral flags to set on the created object

◆ mqtt_obj() [2/2]

MQTT::mqtt_obj::mqtt_obj	(	mqtt_leaf &	parent,
		const char *	topic,
		Client *	mClient,
		uint16_t	flags = (eObj_Flag_PubOnWrite\|eObj_Flag_Subscribe\|eObj_Flag_Sub_NoLocal) )

protected

Constructor for an mqtt_obj with a known parent object.

Parameters

&parent	Reference to parent object.
*topic	Mqtt Topic Name to use for Publish/Subcribe.
*mClient	Pointer to Client to register with. If NULL, it will be registered with the first created Client.
flags	Behavioral flags to set on the created object

Member Function Documentation

◆ AddChild()

virtual mqtt_leaf * MQTT::mqtt_obj::AddChild ( mqtt_leaf * child )

overrideprotectedvirtual

an MqttObj as a child to this object.

Parameters

*child Pointer to the child object to add

Returns: Pointer to the first child of this object

Reimplemented from MQTT::mqtt_leaf.

◆ FindChild()

mqtt_leaf * MQTT::mqtt_obj::FindChild ( const char * topic )

protected

the child object that is registered for the given Topic Name.

Parameters

*topic The Topic Name to find the child for

Returns: Pointer to the child that matches the given Topic Name

◆ GetChildren()

virtual mqtt_leaf * MQTT::mqtt_obj::GetChildren ( )

overrideprotectedvirtual

the first child of this object.

Returns: Pointer to the first child of this object

Reimplemented from MQTT::mqtt_leaf.

◆ GetRenderLength()

virtual int MQTT::mqtt_obj::GetRenderLength ( eObj_Serialize_t form = eObj_Serialize_CURRENT_FORM )

overrideprotectedvirtual

the number of bytes used to serialize this object in a particular format.

Parameters

form	Serialization format to use

Returns: Length of serialized data

Reimplemented from MQTT::mqtt_leaf.

◆ GetSubTopicFilter()

virtual int MQTT::mqtt_obj::GetSubTopicFilter ( NBString & s )

overrideprotectedvirtual

the Subscription Topic Filter this object Subscribes to.

Parameters

&s	The NBString to copy the Subscription Topic Filter into

Returns: eResult_t return code

Reimplemented from MQTT::mqtt_leaf.

◆ ParseFd()

virtual int MQTT::mqtt_obj::ParseFd ( int mqttFd )

overrideprotectedvirtual

the data from a file descriptor according to this object's current default serialization method and assign the value.

Parameters

mqttFd File descriptor to read from.

Returns: eResult_t return code

Implements MQTT::mqtt_leaf.

◆ RemoveFirstChild()

virtual mqtt_leaf * MQTT::mqtt_obj::RemoveFirstChild ( )

overrideprotectedvirtual

Remove the first child from this object.

Returns: Pointer to the new first child of this object

Reimplemented from MQTT::mqtt_leaf.

◆ RenderToBuffer()

virtual int MQTT::mqtt_obj::RenderToBuffer	(	eObj_Serialize_t	form,
		uint8_t *	buf,
		int	buflen )

overridevirtual

Render this object to an output buffer.

Parameters

form	Serialization format to render as
*buf	Pointer to output buffer
buflen	Size of the output buffer

Returns: Length of the rendered data

Implements MQTT::mqtt_leaf.

◆ RenderToFd()

virtual int MQTT::mqtt_obj::RenderToFd	(	eObj_Serialize_t	form,
		int	fd )

overridevirtual

Render this object to an output socket.

Parameters

form	Serialization format to render as
fd	File descriptor to render to

Returns: Length of the rendered data

Implements MQTT::mqtt_leaf.

◆ SetPubState()

virtual void MQTT::mqtt_obj::SetPubState ( uint8_t newState )

overrideprotectedvirtual

the Publish state

Parameters

newState The new Publish state for this object

Reimplemented from MQTT::mqtt_leaf.

◆ SetSubState()

virtual void MQTT::mqtt_obj::SetSubState ( uint8_t newState )

overrideprotectedvirtual

the Subscribe state

Parameters

newState The new Subscribe state for this object

Reimplemented from MQTT::mqtt_leaf.

◆ SubscribeEvent()

virtual int MQTT::mqtt_obj::SubscribeEvent	(	int	mqttFd,
		PacketInfo::Msg *	msg )

overrideprotectedvirtual

Handle a message sent by the Broker triggered by this object's Subscription.

Parameters

mqttFd	File Descriptor to read any additional message data from
*msg	Pointer to message received from the Broker

Returns: eResult_t return code

Reimplemented from MQTT::mqtt_leaf.

◆ TestOrSetValue()

virtual ValueTestResult MQTT::mqtt_obj::TestOrSetValue	(	ParsedJsonDataSet &	pjs,
		bool	setVal )

overridevirtual

whether the current index of a JSON dataset is valid for this object, or assign the value at the current index of the dataset to this object.

Parameters

&pjs	The JSON dataset to use
setVal	true: Assign from the value at the current index, false: test if current index is valid for this object

Returns: ValueTestResult indicating the validity of the current index

Implements MQTT::mqtt_leaf.

The documentation for this class was generated from the following file:

mqtt.h

Public Member Functions

Protected Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ mqtt_obj() [1/2]

◆ mqtt_obj() [2/2]

Member Function Documentation

◆ AddChild()

◆ FindChild()

◆ GetChildren()

◆ GetRenderLength()

◆ GetSubTopicFilter()

◆ ParseFd()

◆ RemoveFirstChild()

◆ RenderToBuffer()

◆ RenderToFd()

◆ SetPubState()

◆ SetSubState()

◆ SubscribeEvent()

◆ TestOrSetValue()