diff --git a/gvafile/gvacommon/.gitignore b/gvafile/gvacommon/.gitignore new file mode 100644 index 0000000..3bb2efd --- /dev/null +++ b/gvafile/gvacommon/.gitignore @@ -0,0 +1,2 @@ +.*.swp +*.pyc diff --git a/gvafile/gvacommon/__init__.py b/gvafile/gvacommon/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/gvafile/gvacommon/celeryrouters.py b/gvafile/gvacommon/celeryrouters.py new file mode 100644 index 0000000..e468813 --- /dev/null +++ b/gvafile/gvacommon/celeryrouters.py @@ -0,0 +1,24 @@ +# -*- coding: utf-8 -*- +from __future__ import unicode_literals + + +class LdapRouter(object): + + def route_for_task(self, task, args=None, kwargs=None): + if 'ldap' in task: + return {'exchange': 'ldap', + 'exchange_type': 'direct', + 'queue': 'ldap'} + return None + + +class FileRouter(object): + + def route_for_task(self, task, args=None, kwargs=None): + if 'file' in task: + return {'exchange': 'file', + 'exchange_type': 'direct', + 'queue': 'file'} + return None + +