6
# kombu.Queue('default', kombu.Exchange('default'), routing_key='default'),
7
# kombu.Queue('import', kombu.Exchange('zodb'), routing_key='zodb.import'),
8
# kombu.Queue('report', kombu.Exchange('zodb'), routing_key='zodb.report'),
5
import celery.app.abstract
6
assert celery.app.abstract # silence pyflakes
14
"exchange": "default",
15
"binding_key": "default",
18
"exchange": "default",
19
"binding_key": "zodb.report",
22
# "exchange": "default",
23
# "binding_key": "zodb.import",
13
kombu.Queue('default', kombu.Exchange('default'), routing_key='default'),
14
# kombu.Queue('import', kombu.Exchange('zodb'), routing_key='zodb.import'),
15
kombu.Queue('report', kombu.Exchange('zodb'), routing_key='zodb.report'),
20
"exchange": "default",
21
"binding_key": "default",
24
"exchange": "default",
25
"binding_key": "zodb.report",
28
"exchange": "default",
29
"binding_key": "zodb.import",
27
33
CELERY_DEFAULT_QUEUE = 'default'
28
34
CELERY_DEFAULT_EXCHANGE_TYPE = 'direct'
29
35
CELERY_DEFAULT_ROUTING_KEY = 'default'
31
CELERY_RESULT_BACKEND = "redis"
32
CELERY_REDIS_HOST = str(os.environ.get('REDIS_HOST', "localhost"))
33
CELERY_REDIS_PORT = int(os.environ.get('REDIS_PORT', 7079))
37
_REDIS_HOST = str(os.environ.get('REDIS_HOST', "localhost"))
38
_REDIS_PORT = int(os.environ.get('REDIS_PORT', 7079))
42
CELERY_RESULT_BACKEND = "redis://%s:%d/%d" % (
43
_REDIS_HOST, _REDIS_PORT, _REDIS_DB)
45
CELERY_RESULT_BACKEND = "redis"
46
CELERY_REDIS_HOST = _REDIS_HOST
47
CELERY_REDIS_PORT = _REDIS_PORT
48
CELERY_REDIS_DB = _REDIS_DB
36
50
_BROKER_REDIS_DB = 0
38
BROKER_URL = "redis://%s:%s/%d" % (
39
CELERY_REDIS_HOST, CELERY_REDIS_PORT, _BROKER_REDIS_DB)
52
BROKER_URL = "redis://%s:%d/%d" % (
53
_REDIS_HOST, _REDIS_PORT, _BROKER_REDIS_DB)
41
55
CELERY_ENABLE_UTC = True