def unsubscribe(self, topic):
        """Unsubscribe from messages on a given topic

        Args:
            topic (string): The MQTT topic to unsubscribe from
        """

        del self.queues[topic]

        try:
            self.client.unsubscribe(topic)
        except operationError as exc:
            raise InternalError("Could not unsubscribe from topic", topic=topic, message=exc.message)
Unsubscribe from messages on a given topic

        Args:
            topic (string): The MQTT topic to unsubscribe from