diff --git a/MQTT/MQTT.cpp b/MQTT/MQTT.cpp index f4c94d9..6b0fd05 100644 --- a/MQTT/MQTT.cpp +++ b/MQTT/MQTT.cpp @@ -13,7 +13,7 @@ MQTT::~MQTT() { } -bool MQTT::Send(const Message& message) +bool MQTT::Send(const MQTTMessage& message) { return m_pMQTTImpl->Send(message); } @@ -39,3 +39,4 @@ void MQTT::Disconnect(size_t connection) } } // namespace MQTT + diff --git a/MQTT/MQTTImpl.cpp b/MQTT/MQTTImpl.cpp index 7ffb9e3..0077b67 100644 --- a/MQTT/MQTTImpl.cpp +++ b/MQTT/MQTTImpl.cpp @@ -32,7 +32,7 @@ MQTTImpl::~MQTTImpl() mosquitto_lib_cleanup(); } -bool MQTTImpl::Send(const Message& message) +bool MQTTImpl::Send(const MQTTMessage& message) { if (m_connected) return (MOSQ_ERR_SUCCESS == mosquitto_publish(m_pMosquitto, NULL, message.topic.c_str(), message.payload.length(), message.payload.c_str(), 0, 0)); @@ -154,7 +154,7 @@ void MQTTImpl::ConnectCallback(int result) void MQTTImpl::MessageCallback(const mosquitto_message* pMessage) { - Message message; + MQTTMessage message; message.topic = std::string(pMessage->topic); message.payload = std::string(static_cast(pMessage->payload), pMessage->payloadlen); diff --git a/MQTT/MQTTImpl.h b/MQTT/MQTTImpl.h index 85956a7..c6b64bd 100644 --- a/MQTT/MQTTImpl.h +++ b/MQTT/MQTTImpl.h @@ -1,8 +1,8 @@ #ifndef MQTT_MQTTIMPL_H #define MQTT_MQTTIMPL_H -#include "Message.h" #include "MQTT.h" +#include "MQTTMessage.h" #include #include #include @@ -20,14 +20,14 @@ public: MQTTImpl(const std::string& hostname, int port); ~MQTTImpl(); - bool Send(const Message& message); + bool Send(const MQTTMessage& message); bool Subscribe(const std::string& topic); void Unsubscribe(const std::string& topic); size_t Connect(MQTT::CallbackMethod function); void Disconnect(size_t connection); private: - typedef Simple::Signal MessageSignal; + typedef Simple::Signal MessageSignal; private: static void ConnectCallback(mosquitto* pMosquitto, void* pObject, int result); diff --git a/include/MQTT.h b/include/MQTT.h index 6fd142f..1635ace 100644 --- a/include/MQTT.h +++ b/include/MQTT.h @@ -1,7 +1,7 @@ #ifndef MQTT_H #define MQTT_H -#include "Message.h" +#include "MQTTMessage.h" #include #include #include @@ -18,10 +18,10 @@ public: ~MQTT(); public: - typedef std::function CallbackMethod; + typedef std::function CallbackMethod; public: - bool Send(const Message& message); + bool Send(const MQTTMessage& message); bool Subscribe(const std::string& topic); void Unsubscribe(const std::string& topic); size_t Connect(CallbackMethod function); diff --git a/include/Message.h b/include/MQTTMessage.h similarity index 55% rename from include/Message.h rename to include/MQTTMessage.h index 03b05e9..2c51aaa 100644 --- a/include/Message.h +++ b/include/MQTTMessage.h @@ -1,12 +1,12 @@ -#ifndef MESSAGE_H -#define MESSAGE_H +#ifndef MQTTMESSAGE_H +#define MQTTMESSAGE_H #include namespace MQTT { -struct Message +struct MQTTMessage { std::string topic; std::string payload; @@ -14,4 +14,4 @@ struct Message } // namespace MQTT -#endif // MESSAGE_H +#endif // MQTTMESSAGE_H