Added support for mqtt protocol