void myqtt_storage_queued_flush ( MyQttCtx ctx,
MyQttConn conn 
)

Allows to redeliver all queued messages associated to the connected session provided.

Parameters
ctxThe context where the operation takes place.
connThe connection that may have pending messages to be redeliver...
Returns
Number of flushed messages, or -1 if it fails.

References myqtt_conn_ref(), myqtt_mutex_lock(), myqtt_mutex_unlock(), and myqtt_thread_pool_new_task().

Referenced by myqtt_conn_send_connect_reply().