MQTT/MQTT/MQTT.cpp

#include "MQTT.h"
#include "MQTTImpl.h"


namespace MQTT {

MQTT::MQTT(const std::string& hostname, int port, int threads) :
	m_pMQTTImpl(new MQTTImpl(hostname, port, threads))
{
}

MQTT::~MQTT()
{
}

bool MQTT::Send(const MQTTMessage& message)
{
	return m_pMQTTImpl->Send(message);
}

bool MQTT::Subscribe(const std::string& topic)
{
	return m_pMQTTImpl->Subscribe(topic);
}

void MQTT::Unsubscribe(const std::string& topic)
{
	m_pMQTTImpl->Unsubscribe(topic);
}

size_t MQTT::Connect(CallbackMethod function)
{
	return m_pMQTTImpl->Connect(function);
}

void MQTT::Disconnect(size_t connection)
{
	m_pMQTTImpl->Disconnect(connection);
}

} // namespace MQTT