24#ifndef __mqtt_iasync_client_h
25#define __mqtt_iasync_client_h
62 virtual void remove_token(
token* tok) = 0;
210 string_ref topic,
const void* payload,
size_t n,
int qos,
bool retained,
238 string_ref topic,
const void* payload,
size_t n,
int qos,
bool retained,
312 const string& topicFilter,
int qos,
358 const std::vector<subscribe_options>& opts = std::vector<subscribe_options>(),
383 const std::vector<subscribe_options>& opts = std::vector<subscribe_options>(),
Definition connect_options.h:50
Definition disconnect_options.h:41
Definition iaction_listener.h:50
Definition iasync_client.h:60
virtual event consume_event()
Definition iasync_client.h:505
virtual void clear_consumer()
Definition iasync_client.h:457
virtual delivery_token_ptr publish(const_message_ptr msg, void *userContext, iaction_listener &cb)=0
virtual void disable_callbacks()=0
virtual void start_consuming()=0
virtual string get_server_uri() const =0
virtual std::vector< delivery_token_ptr > get_pending_delivery_tokens() const =0
virtual bool consumer_closed() noexcept
Definition iasync_client.h:465
virtual bool try_consume_message(const_message_ptr *msg)=0
virtual token_ptr connect()=0
virtual token_ptr unsubscribe(const_string_collection_ptr topicFilters, const properties &props=properties())=0
virtual bool is_connected() const =0
virtual const_message_ptr consume_message()=0
virtual token_ptr connect(connect_options options, void *userContext, iaction_listener &cb)=0
virtual bool try_consume_event(event *evt)
Definition iasync_client.h:514
virtual token_ptr unsubscribe(const_string_collection_ptr topicFilters, void *userContext, iaction_listener &cb, const properties &props=properties())=0
virtual ~iasync_client()
Definition iasync_client.h:71
virtual delivery_token_ptr publish(string_ref topic, const void *payload, size_t n, int qos, bool retained, void *userContext, iaction_listener &cb)=0
virtual token_ptr unsubscribe(const string &topicFilter, void *userContext, iaction_listener &cb, const properties &props=properties())=0
virtual delivery_token_ptr publish(string_ref topic, const void *payload, size_t n)=0
virtual delivery_token_ptr get_pending_delivery_token(int msgID) const =0
virtual delivery_token_ptr publish(string_ref topic, binary_ref payload, int qos, bool retained, const properties &props=properties())=0
virtual std::size_t consumer_queue_size() const
Definition iasync_client.h:486
virtual delivery_token_ptr publish(const_message_ptr msg)=0
virtual void stop_consuming()=0
virtual token_ptr subscribe(const_string_collection_ptr topicFilters, const qos_collection &qos, const std::vector< subscribe_options > &opts=std::vector< subscribe_options >(), const properties &props=properties())=0
virtual bool consumer_done() noexcept
Definition iasync_client.h:475
virtual token_ptr unsubscribe(const string &topicFilter, const properties &props=properties())=0
virtual token_ptr connect(void *userContext, iaction_listener &cb)=0
virtual string get_client_id() const =0
virtual token_ptr subscribe(const_string_collection_ptr topicFilters, const qos_collection &qos, void *userContext, iaction_listener &callback, const std::vector< subscribe_options > &opts=std::vector< subscribe_options >(), const properties &props=properties())=0
virtual token_ptr disconnect(disconnect_options opts)=0
virtual delivery_token_ptr publish(string_ref topic, const void *payload, size_t n, int qos, bool retained, const properties &props=properties())=0
virtual void set_callback(callback &cb)=0
virtual token_ptr disconnect(void *userContext, iaction_listener &cb)=0
virtual token_ptr subscribe(const string &topicFilter, int qos, void *userContext, iaction_listener &callback, const subscribe_options &opts=subscribe_options(), const properties &props=properties())=0
virtual token_ptr reconnect()=0
virtual delivery_token_ptr publish(string_ref topic, binary_ref payload)=0
virtual token_ptr connect(connect_options options)=0
virtual token_ptr subscribe(const string &topicFilter, int qos, const subscribe_options &opts=subscribe_options(), const properties &props=properties())=0
std::vector< int > qos_collection
Definition iasync_client.h:66
virtual token_ptr disconnect(int timeout, void *userContext, iaction_listener &cb)=0
virtual token_ptr disconnect()=0
virtual token_ptr disconnect(int timeout)=0
Definition properties.h:293
Definition subscribe_options.h:49
Definition async_client.h:60
string_collection::const_ptr_t const_string_collection_ptr
Definition string_collection.h:259
token::ptr_t token_ptr
Definition token.h:513
message::const_ptr_t const_message_ptr
Definition message.h:378
delivery_token::ptr_t delivery_token_ptr
Definition delivery_token.h:127