code: def _subscribed(self):
          
          self.logger.debug('Subscription confirmed.')
          self.state = 'subscribed'
          for message in self.message_queue:
              self.send(message)
docs: Called when the subscription was
          accepted successfully.