43 lines
993 B
C++
43 lines
993 B
C++
// Copyright 2023 Dexter.Wan. All Rights Reserved.
|
|
// EMail: 45141961@qq.com
|
|
|
|
#include "topic.h"
|
|
#include "async_client.h"
|
|
|
|
namespace mqtt {
|
|
|
|
/////////////////////////////////////////////////////////////////////////////
|
|
|
|
delivery_token_ptr topic::publish(const void* payload, size_t n)
|
|
{
|
|
return cli_.publish(name_, payload, n, qos_, retained_);
|
|
}
|
|
|
|
delivery_token_ptr topic::publish(const void* payload, size_t n,
|
|
int qos, bool retained)
|
|
{
|
|
return cli_.publish(name_, payload, n, qos, retained);
|
|
}
|
|
|
|
delivery_token_ptr topic::publish(binary_ref payload)
|
|
{
|
|
return cli_.publish(name_, std::move(payload), qos_, retained_);
|
|
}
|
|
|
|
delivery_token_ptr topic::publish(binary_ref payload, int qos, bool retained)
|
|
{
|
|
return cli_.publish(name_, std::move(payload), qos, retained);
|
|
}
|
|
|
|
token_ptr topic::subscribe(const subscribe_options& opts)
|
|
{
|
|
return cli_.subscribe(name_, qos_, opts);
|
|
}
|
|
|
|
/////////////////////////////////////////////////////////////////////////////
|
|
// end namespace mqtt
|
|
}
|
|
|
|
|
|
|