Use a direct exchange instead of topic

We do exact matching between routing key and queue, so a topic exchange is not required.
nimbusproject · Jan 20, 2012 · 18c1e67 · 18c1e67
1 parent 5f25c30
commit 18c1e67
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dashi/__init__.py b/dashi/__init__.py
@@ -24,7 +24,7 @@ def __init__(self, name, uri, exchange, durable=False, auto_delete=True, seriali
         self._conn = BrokerConnection(uri)
         self._name = name
         self._exchange_name = exchange
-        self._exchange = Exchange(name=exchange, type='topic',
+        self._exchange = Exchange(name=exchange, type='direct',
                                   durable=durable, auto_delete=auto_delete)
 
         # visible attributes