def METHOD_NAME(self, message, session):
    if self.data['transport']['type'] == 'asq':
        queue_uri = self.data['transport']['queue']
        return self.send_to_azure_queue(queue_uri, message, session)