MQTTSuite
Loading...
Searching...
No Matches
mqtt::mqttbroker::lib::MqttModel::EventReceiver Class Reference
Collaboration diagram for mqtt::mqttbroker::lib::MqttModel::EventReceiver:

Public Member Functions

 EventReceiver (std::uint64_t id, const std::shared_ptr< express::Response > &response)
 ~EventReceiver ()
std::uint64_t getId () const

Public Attributes

std::uint64_t id
std::weak_ptr< express::Response > response
core::timer::Timer heartbeatTimer

Detailed Description

Definition at line 77 of file MqttModel.h.

Constructor & Destructor Documentation

◆ EventReceiver()

mqtt::mqttbroker::lib::MqttModel::EventReceiver::EventReceiver ( std::uint64_t id,
const std::shared_ptr< express::Response > & response )

Definition at line 158 of file MqttModel.cpp.

159 : id(id)
161 , heartbeatTimer(core::timer::Timer::intervalTimer(
162 [response] {
163 if (response->isConnected()) {
164 response->sendFragment(":keep-alive");
165 response->sendFragment();
166 }
167 },
168 39)) {
169 }
std::weak_ptr< express::Response > response
Definition MqttModel.h:88

References heartbeatTimer, id, and response.

◆ ~EventReceiver()

mqtt::mqttbroker::lib::MqttModel::EventReceiver::~EventReceiver ( )

Definition at line 171 of file MqttModel.cpp.

171 {
172 heartbeatTimer.cancel();
173 }

References heartbeatTimer.

Member Function Documentation

◆ getId()

std::uint64_t mqtt::mqttbroker::lib::MqttModel::EventReceiver::getId ( ) const
inline

Definition at line 83 of file MqttModel.h.

83 {
84 return id;
85 }

References id.

Referenced by mqtt::mqttbroker::lib::MqttModel::addEventReceiver().

Here is the caller graph for this function:

Member Data Documentation

◆ heartbeatTimer

core::timer::Timer mqtt::mqttbroker::lib::MqttModel::EventReceiver::heartbeatTimer

Definition at line 90 of file MqttModel.h.

Referenced by EventReceiver(), and ~EventReceiver().

◆ id

std::uint64_t mqtt::mqttbroker::lib::MqttModel::EventReceiver::id

Definition at line 87 of file MqttModel.h.

Referenced by EventReceiver(), and getId().

◆ response

std::weak_ptr<express::Response> mqtt::mqttbroker::lib::MqttModel::EventReceiver::response

Definition at line 88 of file MqttModel.h.

Referenced by EventReceiver(), and mqtt::mqttbroker::lib::MqttModel::sendEvent().


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