rllib  1
Public Types | Public Member Functions | Private Member Functions | Private Attributes | List of all members
rlMQTT Class Reference

#include <rlmqtt.h>

Inheritance diagram for rlMQTT:
Inheritance graph
[legend]
Collaboration diagram for rlMQTT:
Collaboration graph
[legend]

Public Types

enum  ControlPacketType {
  Reserved0 = 0, CONNECT = 1, CONNACK = 2, PUBLISH = 3,
  PUBACK = 4, PUBREC = 5, PUBREL = 6, PUBCOMP = 7,
  SUBSCRIBE = 8, SUBACK = 9, UNSUBSCRIBE = 10, UNSUBACK = 11,
  PINGREQ = 12, PINGRESP = 13, DISCONNECT = 14, Reserved15 = 15
}
 
- Public Types inherited from rlSocket
enum  SocketEnum {
  SOCKET_ERR = -1, SETSOCKOPT_ERR = -2, LISTEN_ERR = -3, ACCEPT_ERR = -4,
  INET_ADDR_ERR = -5, CONNECT_ERR = -6, PORT_ERR = -7
}
 

Public Member Functions

 rlMQTT (const char *adr)
 
virtual ~rlMQTT ()
 
int sendCONNECT (int connect_flags=0)
 
int sendCONNACK ()
 
int sendPUBLISH ()
 
int sendPUBACK ()
 
int sendPUBREC ()
 
int sendPUBREL ()
 
int sendPUBCOMP ()
 
int sendSUBSCRIBE ()
 
int sendSUBACK ()
 
int sendUNSUBSCRIBE ()
 
int sendUNSUBACK ()
 
int sendPINGREQ ()
 
int sendPINGRESP ()
 
int sendDISCONNECT ()
 
int receivePacket ()
 
- Public Member Functions inherited from rlSocket
 rlSocket (const char *adr, int port, int active)
 
 rlSocket (int socket)
 
virtual ~rlSocket ()
 
void setAdr (const char *adr)
 
void setPort (int port)
 
int getPort ()
 
void setActive (int active)
 
int read (void *buf, int len, int timeout=0)
 
int readStr (char *buf, int len, int timeout=0)
 
int readHttpHeader (rlString *header, int timeout=0)
 
int write (const void *buf, int len)
 
int printf (const char *format,...)
 
int connect ()
 
int disconnect ()
 
int select (int timeout=0)
 
int isConnected ()
 
int setIPVersion (int version)
 
int getIPVersion ()
 
int sendProcessViewBrowserButtonEvent (int id)
 
int rlGetsockopt (int level, int optname)
 
int rlSetsockopt (int level, int optname)
 
int readHttpContentLength (int timeout)
 

Private Member Functions

int sendFixedHeader (int control_packet_type, int remaining_length=0, int flags=0)
 
int sendString (const char *text)
 

Private Attributes

int last_send_control_packet_type
 
int last_send_flags
 
int last_send_packet_identifier
 

Additional Inherited Members

- Static Public Member Functions inherited from rlSocket
static int rlGetsockopt (int sockfd, int level, int optname, void *optval, int *optlen)
 
static int rlSetsockopt (int sockfd, int level, int optname, const void *optval, int optlen)
 
- Public Attributes inherited from rlSocket
int s
 
unsigned char sockaddr [16+48]
 

Detailed Description

class for communication with MQTT
See:
http://docs.oasis-open.org/mqtt/mqtt/v5.0/mqtt-v5.0.html
Test server:
http://test.mosquitto.org/
 

Definition at line 32 of file rlmqtt.h.

Member Enumeration Documentation

◆ ControlPacketType

Enumerator
Reserved0 
CONNECT 
CONNACK 
PUBLISH 
PUBACK 
PUBREC 
PUBREL 
PUBCOMP 
SUBSCRIBE 
SUBACK 
UNSUBSCRIBE 
UNSUBACK 
PINGREQ 
PINGRESP 
DISCONNECT 
Reserved15 

Definition at line 35 of file rlmqtt.h.

36  {
37  Reserved0 = 0, // Forbidden Reserved
38  CONNECT = 1, // Client to Server Client request to connect to Server
39  CONNACK = 2, // Server to Client Connect acknowledgment
40  PUBLISH = 3, // Client to Server or Server to Client / Publish message
41  PUBACK = 4, // Client to Server or Server to Client / Publish acknowledgment
42  PUBREC = 5, // Client to Server or Server to Client / Publish received (assured delivery part 1)
43  PUBREL = 6, // Client to Server or Server to Client / Publish release (assured delivery part 2)
44  PUBCOMP = 7, // Client to Server or Server to Client / Publish complete (assured delivery part 3)
45  SUBSCRIBE = 8, // Client to Server Client subscribe request
46  SUBACK = 9, // Server to Client Subscribe acknowledgment
47  UNSUBSCRIBE = 10, // Client to Server Unsubscribe request
48  UNSUBACK = 11, // Server to Client Unsubscribe acknowledgment
49  PINGREQ = 12, // Client to Server PING request
50  PINGRESP = 13, // Server to Client PING response
51  DISCONNECT = 14, // Client to Server Client is disconnecting
52  Reserved15 = 15 // Forbidden Reserved
53  };

Constructor & Destructor Documentation

◆ rlMQTT()

rlMQTT::rlMQTT ( const char *  adr)

◆ ~rlMQTT()

virtual rlMQTT::~rlMQTT ( )
virtual

Member Function Documentation

◆ receivePacket()

int rlMQTT::receivePacket ( )

◆ sendCONNACK()

int rlMQTT::sendCONNACK ( )

◆ sendCONNECT()

int rlMQTT::sendCONNECT ( int  connect_flags = 0)
 

◆ sendDISCONNECT()

int rlMQTT::sendDISCONNECT ( )

◆ sendFixedHeader()

int rlMQTT::sendFixedHeader ( int  control_packet_type,
int  remaining_length = 0,
int  flags = 0 
)
private

◆ sendPINGREQ()

int rlMQTT::sendPINGREQ ( )

◆ sendPINGRESP()

int rlMQTT::sendPINGRESP ( )

◆ sendPUBACK()

int rlMQTT::sendPUBACK ( )

◆ sendPUBCOMP()

int rlMQTT::sendPUBCOMP ( )

◆ sendPUBLISH()

int rlMQTT::sendPUBLISH ( )

◆ sendPUBREC()

int rlMQTT::sendPUBREC ( )

◆ sendPUBREL()

int rlMQTT::sendPUBREL ( )

◆ sendString()

int rlMQTT::sendString ( const char *  text)
private

◆ sendSUBACK()

int rlMQTT::sendSUBACK ( )

◆ sendSUBSCRIBE()

int rlMQTT::sendSUBSCRIBE ( )

◆ sendUNSUBACK()

int rlMQTT::sendUNSUBACK ( )

◆ sendUNSUBSCRIBE()

int rlMQTT::sendUNSUBSCRIBE ( )

Member Data Documentation

◆ last_send_control_packet_type

int rlMQTT::last_send_control_packet_type
private

Definition at line 80 of file rlmqtt.h.

◆ last_send_flags

int rlMQTT::last_send_flags
private

Definition at line 80 of file rlmqtt.h.

◆ last_send_packet_identifier

int rlMQTT::last_send_packet_identifier
private

Definition at line 80 of file rlmqtt.h.


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