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>(),
459 #endif // __mqtt_iasync_client_h message::const_ptr_t const_message_ptr
Definition: message.h:368
virtual void set_callback(callback &cb)=0
virtual bool try_consume_message(const_message_ptr *msg)=0
Definition: iaction_listener.h:48
string_collection::const_ptr_t const_string_collection_ptr
Definition: string_collection.h:234
Definition: connect_options.h:48
virtual delivery_token_ptr publish(string_ref topic, const void *payload, size_t n, int qos, bool retained)=0
virtual const_message_ptr consume_message()=0
virtual bool is_connected() const =0
virtual token_ptr unsubscribe(const string &topicFilter, const properties &props=properties())=0
virtual void stop_consuming()=0
virtual token_ptr reconnect()=0
virtual void disable_callbacks()=0
virtual delivery_token_ptr get_pending_delivery_token(int msgID) const =0
Definition: properties.h:255
Definition: iasync_client.h:58
virtual std::vector< delivery_token_ptr > get_pending_delivery_tokens() const =0
virtual string get_server_uri() const =0
virtual token_ptr disconnect()=0
token::ptr_t token_ptr
Definition: token.h:506
delivery_token::ptr_t delivery_token_ptr
Definition: delivery_token.h:125
Definition: subscribe_options.h:41
virtual string get_client_id() const =0
Definition: callback.h:41
virtual token_ptr connect()=0
Definition: async_client.h:49
std::vector< int > qos_collection
Definition: iasync_client.h:65
virtual void start_consuming()=0
virtual ~iasync_client()
Definition: iasync_client.h:70
Definition: disconnect_options.h:39
virtual token_ptr subscribe(const string &topicFilter, int qos, const subscribe_options &opts=subscribe_options(), const properties &props=properties())=0