from kombu import Exchange
from kombu import Queue

from bulkperformancerights import config


CELERY_IGNORE_RESULT = True
CELERY_STORE_ERRORS_EVEN_IF_IGNORED = False

CELERY_DEFAULT_QUEUE = config.broker_queue_name
CELERY_QUEUES = (Queue(
    config.broker_queue_name,
    Exchange(config.broker_queue_name)),)

BROKER_TRANSPORT_OPTIONS = {
    'queue_name_prefix': config.queue_prefix
}