#include "aitt_internal.h"
-AittOption::AittOption() : clear_session_(false), use_custom_broker(false)
+AittOption::AittOption() : clean_session_(false), use_custom_broker(false)
{
}
-AittOption::AittOption(bool clear_session, bool use_custom_mqtt_broker)
- : clear_session_(clear_session), use_custom_broker(use_custom_mqtt_broker)
+AittOption::AittOption(bool clean_session, bool use_custom_mqtt_broker)
+ : clean_session_(clean_session), use_custom_broker(use_custom_mqtt_broker)
{
}
-void AittOption::SetClearSession(bool val)
+void AittOption::SetCleanSession(bool val)
{
- clear_session_ = val;
+ clean_session_ = val;
}
-bool AittOption::GetClearSession() const
+bool AittOption::GetCleanSession() const
{
- return clear_session_;
+ return clean_session_;
}
void AittOption::SetUseCustomMqttBroker(bool val)
class API AittOption {
public:
AittOption();
- explicit AittOption(bool clear_session, bool use_custom_broker);
+ explicit AittOption(bool clean_session, bool use_custom_broker);
~AittOption() = default;
- void SetClearSession(bool val);
- bool GetClearSession() const;
+ void SetCleanSession(bool val);
+ bool GetCleanSession() const;
void SetUseCustomMqttBroker(bool val);
bool GetUseCustomMqttBroker() const;
void SetServiceID(const std::string &id);
const char *GetCustomRWFile() const;
private:
- bool clear_session_;
+ bool clean_session_;
bool use_custom_broker;
std::string service_id;
std::string location_id;
if (option.GetUseCustomMqttBroker()) {
mq = modules.NewCustomMQ(id, option);
AittOption discovery_option = option;
- discovery_option.SetClearSession(false);
+ discovery_option.SetCleanSession(false);
discovery.SetMQ(modules.NewCustomMQ(id + 'd', option));
} else {
- mq = std::unique_ptr<MQ>(new MosquittoMQ(id, option.GetClearSession()));
+ mq = std::unique_ptr<MQ>(new MosquittoMQ(id, option.GetCleanSession()));
discovery.SetMQ(std::unique_ptr<MQ>(new MosquittoMQ(id + 'd', false)));
}
aittThread = std::thread(&AITT::Impl::ThreadMain, this);
const std::string MosquittoMQ::REPLY_SEQUENCE_NUM_KEY = "sequenceNum";
const std::string MosquittoMQ::REPLY_IS_END_SEQUENCE_KEY = "isEndSequence";
-MosquittoMQ::MosquittoMQ(const std::string &id, bool clear_session)
+MosquittoMQ::MosquittoMQ(const std::string &id, bool clean_session)
: handle(nullptr),
keep_alive(60),
subscribers_iterating(false),
break;
}
- handle = mosquitto_new(id.c_str(), clear_session, this);
+ handle = mosquitto_new(id.c_str(), clean_session, this);
if (handle == nullptr) {
- ERR("mosquitto_new(%s, %d) Fail", id.c_str(), clear_session);
+ ERR("mosquitto_new(%s, %d) Fail", id.c_str(), clean_session);
break;
}
class MosquittoMQ : public MQ {
public:
- explicit MosquittoMQ(const std::string &id, bool clear_session = false);
+ explicit MosquittoMQ(const std::string &id, bool clean_session = false);
virtual ~MosquittoMQ(void);
void SetConnectionCallback(const MQConnectionCallback &cb);
case AITT_OPT_CLEAN_SESSION:
ret = _to_boolean(value, bool_val);
if (ret == AITT_ERROR_NONE)
- handle->option.SetClearSession(bool_val);
+ handle->option.SetCleanSession(bool_val);
return ret;
case AITT_OPT_CUSTOM_BROKER:
ret = _to_boolean(value, bool_val);
case AITT_OPT_MY_IP:
return handle->my_ip;
case AITT_OPT_CLEAN_SESSION:
- return (handle->option.GetClearSession()) ? "true" : "false";
+ return (handle->option.GetCleanSession()) ? "true" : "false";
case AITT_OPT_CUSTOM_BROKER:
return (handle->option.GetUseCustomMqttBroker()) ? "true" : "false";
default: