From 3f0a387aa6feabb8b704fcd5ff40e32d733812a3 Mon Sep 17 00:00:00 2001
From: Vince Gonzalez <vince.gonzalez@gmail.com>
Date: Mon, 9 Sep 2013 11:46:55 -0400
Subject: [PATCH] SimpleQueue: allow override of exchange_type

---
 kombu/simple.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/kombu/simple.py b/kombu/simple.py
index 7fa08aec..0634eee9 100644
--- a/kombu/simple.py
+++ b/kombu/simple.py
@@ -101,7 +101,7 @@ class SimpleBase(object):
 class SimpleQueue(SimpleBase):
     no_ack = False
     queue_opts = {}
-    exchange_opts = {}
+    exchange_opts = { 'type': 'direct' }
 
     def __init__(self, channel, name, no_ack=None, queue_opts=None,
                  exchange_opts=None, serializer=None,
@@ -112,7 +112,7 @@ class SimpleQueue(SimpleBase):
         if no_ack is None:
             no_ack = self.no_ack
         if not isinstance(queue, entity.Queue):
-            exchange = entity.Exchange(name, 'direct', **exchange_opts)
+            exchange = entity.Exchange(name, **exchange_opts)
             queue = entity.Queue(name, exchange, name, **queue_opts)
         else:
             name = queue.name