def __init__(self, beaver_config, logger=None):
super(MqttTransport, self).__init__(beaver_config, logger=logger)<EOL>self._client = paho.Client(beaver_config.get('<STR_LIT>'), clean_session=True)<EOL>self._topic = beaver_config.get('<STR_LIT>')<EOL>self._client.connect(<EOL>host=beaver_config.get('<STR_LIT>'),<EOL>port=beaver_config.get('<STR_LIT>'),<EOL>keepalive=int(beaver_config.get('<STR_LIT>'))<EOL>)<EOL>def on_disconnect(mosq, obj, rc):<EOL><INDENT>if rc == <NUM_LIT:0>:<EOL><INDENT>logger.debug('<STR_LIT>')<EOL><DEDENT>else:<EOL><INDENT>logger.debug('<STR_LIT>')<EOL><DEDENT><DEDENT>self._client.on_disconnect = on_disconnect<EOL>
Paho client initialization. Once this this transport is initialized
it has invoked a connection to the server