Called when the subscription was
        accepted successfully.

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