#include <datastream_mqtt.h>
Public Member Functions | |
DataStreamMQTT () | |
virtual bool | isDebugPlugin () override |
virtual bool | isRunning () const override |
virtual const char * | name () const override |
virtual void | shutdown () override |
virtual bool | start (QStringList *) override |
virtual | ~DataStreamMQTT () override |
Public Member Functions inherited from PJ::DataStreamer | |
MessageParserFactory * | availableParsers () |
PlotDataMapRef & | dataMap () |
const PlotDataMapRef & | dataMap () const |
DataStreamer () | |
std::mutex & | mutex () |
void | setAvailableParsers (MessageParserFactory *parsers) |
void | setMaximumRange (double range) |
virtual | ~DataStreamer ()=default |
Public Member Functions inherited from PJ::PlotJugglerPlugin | |
virtual const std::vector< QAction * > & | availableActions () |
virtual QWidget * | optionsWidget () |
PlotJugglerPlugin () | |
virtual bool | xmlLoadState (const QDomElement &parent_element) |
virtual bool | xmlSaveState (QDomDocument &doc, QDomElement &parent_element) const |
QDomElement | xmlSaveState (QDomDocument &doc) const |
Public Attributes | |
MQTTAsync | _client |
bool | _disconnection_done |
QString | _error_msg |
bool | _finished |
std::unordered_map< std::string, PJ::MessageParserPtr > | _parsers |
QString | _protocol |
bool | _protocol_issue |
QTimer | _protocol_issue_timer |
int | _qos |
bool | _subscribed |
QString | _topic_filter |
Private Attributes | |
bool | _running |
Additional Inherited Members | |
Signals inherited from PJ::DataStreamer | |
void | clearBuffers () |
void | closed () |
void | dataReceived () |
Definition at line 15 of file datastream_mqtt.h.
DataStreamMQTT::DataStreamMQTT | ( | ) |
Definition at line 175 of file datastream_mqtt.cpp.
|
overridevirtual |
Definition at line 385 of file datastream_mqtt.cpp.
|
inlineoverridevirtual |
Reimplemented from PJ::PlotJugglerPlugin.
Definition at line 37 of file datastream_mqtt.h.
|
overridevirtual |
Implements PJ::DataStreamer.
Definition at line 380 of file datastream_mqtt.cpp.
|
inlineoverridevirtual |
Implements PJ::PlotJugglerPlugin.
Definition at line 32 of file datastream_mqtt.h.
|
overridevirtual |
Implements PJ::DataStreamer.
Definition at line 347 of file datastream_mqtt.cpp.
|
overridevirtual |
Implements PJ::DataStreamer.
Definition at line 197 of file datastream_mqtt.cpp.
MQTTAsync DataStreamMQTT::_client |
Definition at line 45 of file datastream_mqtt.h.
bool DataStreamMQTT::_disconnection_done |
Definition at line 42 of file datastream_mqtt.h.
QString DataStreamMQTT::_error_msg |
Definition at line 47 of file datastream_mqtt.h.
bool DataStreamMQTT::_finished |
Definition at line 44 of file datastream_mqtt.h.
std::unordered_map<std::string, PJ::MessageParserPtr> DataStreamMQTT::_parsers |
Definition at line 52 of file datastream_mqtt.h.
QString DataStreamMQTT::_protocol |
Definition at line 49 of file datastream_mqtt.h.
bool DataStreamMQTT::_protocol_issue |
Definition at line 54 of file datastream_mqtt.h.
QTimer DataStreamMQTT::_protocol_issue_timer |
Definition at line 55 of file datastream_mqtt.h.
int DataStreamMQTT::_qos |
Definition at line 51 of file datastream_mqtt.h.
|
private |
Definition at line 58 of file datastream_mqtt.h.
bool DataStreamMQTT::_subscribed |
Definition at line 43 of file datastream_mqtt.h.
QString DataStreamMQTT::_topic_filter |
Definition at line 50 of file datastream_mqtt.h.