25#ifndef __mqtt_iasync_client_h
26#define __mqtt_iasync_client_h
61 virtual void remove_token(
token* tok) =0;
208 const void* payload,
size_t n,
209 int qos,
bool retained) =0;
219 const void* payload,
size_t n) =0;
236 const void* payload,
size_t n,
237 int qos,
bool retained,
251 int qos,
bool retained) =0;
350 const std::vector<subscribe_options>& opts=std::vector<subscribe_options>(),
374 const std::vector<subscribe_options>& opts=std::vector<subscribe_options>(),
Definition: callback.h:42
Definition: connect_options.h:49
Definition: disconnect_options.h:40
Definition: iaction_listener.h:49
Definition: iasync_client.h:59
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 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 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:70
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(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 token_ptr unsubscribe(const string &topicFilter, const properties &props=properties())=0
virtual token_ptr connect(void *userContext, iaction_listener &cb)=0
virtual delivery_token_ptr publish(string_ref topic, binary_ref payload, int qos, bool retained)=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 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 delivery_token_ptr publish(string_ref topic, const void *payload, size_t n, int qos, bool retained)=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:65
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:256
Definition: subscribe_options.h:42
Definition: async_client.h:49
string_collection::const_ptr_t const_string_collection_ptr
Definition: string_collection.h:234
token::ptr_t token_ptr
Definition: token.h:506
message::const_ptr_t const_message_ptr
Definition: message.h:368
delivery_token::ptr_t delivery_token_ptr
Definition: delivery_token.h:125