Add 'gvapgsql/gvacommon/' from commit '546441d49920caf43eb7d33976c2d71ae85f16d5'

git-subtree-dir: gvapgsql/gvacommon
git-subtree-mainline: e9c1a218d6
git-subtree-split: 546441d499

gvapgsql/gvacommon/.gitignore

@@ -0,0 +1,3 @@
+.*.swp
+*.pyc
+.ropeproject/

gvapgsql/gvacommon/celeryrouters.py

@@ -0,0 +1,15 @@
+# -*- coding: utf-8 -*-
+from __future__ import unicode_literals
+
+
+class GvaRouter(object):
+
+    def route_for_task(self, task, args=None, kwargs=None):
+        for route in ['ldap', 'file', 'mysql', 'pgsql']:
+            if route in task:
+                return {
+                    'exchange': route,
+                    'exchange_type': 'direct',
+                    'queue': route,
+                }
+        return None