add cancel func to mqtt protocol!
add cancel func to mqtt protocol!