def create_queue(self, queue_name, attributes=None):
    queue = None
    if (not attributes):
        attributes = {'DelaySeconds': '5'}
    sqs = self.connect()
    try:
        queue = sqs.create_queue(QueueName=queue_name, Attributes=attributes)
    except Exception as err:
        self.logger.error(err)
        self.exception = err
    return queue
def create_queue(self, queue_name, attributes=None):
    queue = None
    if (not attributes):
        attributes = {'DelaySeconds': '5'}
    sqs = self.connect()
    try:
        queue = sqs.create_queue(QueueName=queue_name, Attributes=attributes)
    except Exception as err:
        self.logger.error(err)
        self.exception = err
    return queue