|
18 | 18 |
|
19 | 19 | #pragma once |
20 | 20 |
|
21 | | -#include <cc_tools_qt/Filter.h> |
| 21 | +#include <cc_tools_qt/ToolsFilter.h> |
22 | 22 | #include <cc_tools_qt/version.h> |
23 | 23 |
|
24 | 24 | #include <cc_mqttsn_client/client.h> |
|
32 | 32 | #include <memory> |
33 | 33 | #include <string> |
34 | 34 |
|
35 | | -static_assert(CC_MQTTSN_CLIENT_MAKE_VERSION(2, 0, 4) <= CC_MQTTSN_CLIENT_VERSION, "The version of the cc_mqttsn_client library is too old"); |
36 | | -static_assert(CC_TOOLS_QT_MAKE_VERSION(5, 3, 3) <= CC_TOOLS_QT_VERSION, "The version of the cc_tools_qt library is too old"); |
| 35 | +static_assert(CC_MQTTSN_CLIENT_MAKE_VERSION(2, 0, 7) <= CC_MQTTSN_CLIENT_VERSION, "The version of the cc_mqttsn_client library is too old"); |
| 36 | +static_assert(CC_TOOLS_QT_MAKE_VERSION(6, 0, 0) <= CC_TOOLS_QT_VERSION, "The version of the cc_tools_qt library is too old"); |
37 | 37 |
|
38 | 38 | namespace cc_plugin_mqttsn_client_filter |
39 | 39 | { |
40 | 40 |
|
41 | | -class MqttsnClientFilter final : public QObject, public cc_tools_qt::Filter |
| 41 | +class MqttsnClientFilter final : public cc_tools_qt::ToolsFilter |
42 | 42 | { |
43 | 43 | Q_OBJECT |
44 | 44 |
|
@@ -85,8 +85,8 @@ class MqttsnClientFilter final : public QObject, public cc_tools_qt::Filter |
85 | 85 | protected: |
86 | 86 | virtual bool startImpl() override; |
87 | 87 | virtual void stopImpl() override; |
88 | | - virtual QList<cc_tools_qt::DataInfoPtr> recvDataImpl(cc_tools_qt::DataInfoPtr dataPtr) override; |
89 | | - virtual QList<cc_tools_qt::DataInfoPtr> sendDataImpl(cc_tools_qt::DataInfoPtr dataPtr) override; |
| 88 | + virtual QList<cc_tools_qt::ToolsDataInfoPtr> recvDataImpl(cc_tools_qt::ToolsDataInfoPtr dataPtr) override; |
| 89 | + virtual QList<cc_tools_qt::ToolsDataInfoPtr> sendDataImpl(cc_tools_qt::ToolsDataInfoPtr dataPtr) override; |
90 | 90 | virtual void socketConnectionReportImpl(bool connected) override; |
91 | 91 | virtual void applyInterPluginConfigImpl(const QVariantMap& props) override; |
92 | 92 | virtual const char* debugNameImpl() const override; |
@@ -132,15 +132,15 @@ private slots: |
132 | 132 |
|
133 | 133 | ClientPtr m_client; |
134 | 134 | QTimer m_timer; |
135 | | - std::list<cc_tools_qt::DataInfoPtr> m_pendingData; |
| 135 | + std::list<cc_tools_qt::ToolsDataInfoPtr> m_pendingData; |
136 | 136 | Config m_config; |
137 | 137 | std::string m_prevClientId; |
138 | 138 | unsigned m_tickMs = 0U; |
139 | 139 | qint64 m_tickMeasureTs = 0; |
140 | | - cc_tools_qt::DataInfoPtr m_recvDataPtr; |
141 | | - QList<cc_tools_qt::DataInfoPtr> m_recvData; |
142 | | - cc_tools_qt::DataInfoPtr m_sendDataPtr; |
143 | | - QList<cc_tools_qt::DataInfoPtr> m_sendData; |
| 140 | + cc_tools_qt::ToolsDataInfoPtr m_recvDataPtr; |
| 141 | + QList<cc_tools_qt::ToolsDataInfoPtr> m_recvData; |
| 142 | + cc_tools_qt::ToolsDataInfoPtr m_sendDataPtr; |
| 143 | + QList<cc_tools_qt::ToolsDataInfoPtr> m_sendData; |
144 | 144 | bool m_firstConnect = true; |
145 | 145 | bool m_socketConnected = false; |
146 | 146 | bool m_cleanSession = false; |
|
0 commit comments