mosquitto_lib_cleanup();
reinitialise(("mosq/" + m_ClientId + "/" + m_ServiceName + "//").c_str(), true);
if (mosqpp::lib_init() != MOSQ_ERR_SUCCESS)
{
    throw std::runtime_error("CMQTTCommunicator: can't intialize library.");
}

mosqpp::mosquittopp::int_option(MOSQ_OPT_PROTOCOL_VERSION, MQTT_PROTOCOL_V5);
// Last will and testament
const std::string WillMessage = Json(Json::object{{ "service", m_ServiceName }, {"status", "Disconnected"}}).dump();
will_set((m_FullServiceIdentifier + "status").c_str(), WillMessage.length(), WillMessage.c_str(), static_cast<int>(EQualityOfService::DeliverAtLeastOnce));

if (connect(m_MQTTBrokerAddress.GetIPAddress().ToString().c_str(), m_MQTTBrokerAddress.GetPort(), KeepAliveSec) != MOSQ_ERR_SUCCESS)
{
    throw CApplicationException("CMQTTCommunicator: could not connect to mosquitto broker");
}