NetBurner 3.5.6
PDF Version |
MqttObj connecting hardware GPIO pins to an Mqtt Broker. This class defaults the pin to an Output state. More...
#include <mqtt.h>
Inherits MQTT::mqtt_IO.
Public Member Functions | |
mqtt_IO_Output (PinIO ioPin, const char *topic, Client *client=NULL, uint16_t flags=0) | |
Constructor for a standalone mqtt_IO_Output object. | |
mqtt_IO_Output (mqtt_leaf &parent, PinIO ioPin, const char *topic, Client *client=NULL, uint16_t flags=0) | |
Constructor for a mqtt_IO_Output object that has a parent. | |
mqtt_IO & | operator= (bool val) |
Assignment operator for mqtt_IO. Assigns the value to the hardware GPIO, then performs any post assignment operations. | |
![]() | |
mqtt_IO (PinIO ioPin, const char *topic, Client *mClient=NULL, uint16_t flags=(eObj_Flag_PubOnWrite|eObj_Flag_Subscribe|eObj_Flag_Sub_NoLocal)) | |
Constructor for a standalone mqtt_IO object. | |
mqtt_IO (mqtt_leaf &parent, PinIO ioPin, const char *topic, Client *mClient=NULL, uint16_t flags=(eObj_Flag_PubOnWrite|eObj_Flag_Subscribe|eObj_Flag_Sub_NoLocal)) | |
Constructor for a mqtt_IO object that has a parent. | |
virtual void | SetFlags (uint16_t newFlags) override |
additional behavioral flags for this object | |
virtual void | ClearFlags (uint16_t delFlags) override |
behavioral flags from this object | |
int | SetFixedDirection (int direction) |
Set a fixed direction for the GPIO pin. | |
mqtt_IO & | operator= (bool val) |
Assignment operator for mqtt_IO. Assigns the value to the hardware GPIO, then performs any post assignment operations. | |
operator bool () | |
Boolean conversion operator for mqtt_IO. Returns the current state of the underlying GPIO. | |
bool | operator! () |
Boolean Not operator for mqtt_IO. Returns the negation of the current state of the underlying GPIO. | |
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 | SubscribeEvent (int mqttFd, PacketInfo::Msg *msg) override |
Handle a message sent by the Broker triggered by this object's Subscription. | |
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. | |
![]() | |
~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. | |
virtual int | GetSubTopicFilter (NBString &s) |
Get the Subscription Topic Filter this object Subscribes to. | |
virtual int | GetRenderLength (eObj_Serialize_t form=eObj_Serialize_CURRENT_FORM) |
Get the number of bytes used to serialize this object in a particular format. | |
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. | |
uint16_t | GetFlags () |
Get the behavioral flags set for this object. | |
int | getPriority () |
Get the message priority for this object. | |
Additional Inherited Members | |
![]() | |
enum | eObj_State_t |
Mqtt Object Publication/Subscription States. | |
![]() | |
static void | PinNotify (int port_num, int pin, void *ctx) |
Static notification function for pin state changes. | |
![]() | |
static int | MqttRxPublish (Client *mClient, int mqttFd, PacketInfo::Msg *msg, void *ctx) |
Static message handler for Publish messages received by the registered Client. | |
![]() | |
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. | |
![]() | |
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. | |
virtual mqtt_leaf * | GetChildren () |
Get the first child of this object. | |
virtual mqtt_leaf * | AddChild (mqtt_leaf *child) |
Add an MqttObj as a child to this object. | |
virtual mqtt_leaf * | RemoveFirstChild () |
Remove the first child from this object. | |
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. | |
virtual void | SetPubState (uint8_t newState) |
Set the Publish state. | |
virtual void | SetSubState (uint8_t newState) |
Set the Subscribe state. | |
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. | |
![]() | |
NBInterpolatedString | topicName |
Topic name or additional branch. | |
eObj_Serialize_t | publishForm |
Default serialization form. | |
uint16_t | mFlags |
Behavioral flags. | |
MqttObj connecting hardware GPIO pins to an Mqtt Broker. This class defaults the pin to an Output state.
|
inline |
Constructor for a standalone mqtt_IO_Output object.
|
inline |
Constructor for a mqtt_IO_Output object that has a parent.
mqtt_IO & MQTT::mqtt_IO::operator= | ( | bool | val | ) |
Assignment operator for mqtt_IO. Assigns the value to the hardware GPIO, then performs any post assignment operations.
val | The value to assign to the pin. |