Allow the specification of durable queues and exchanges in bind-channel.

minimal · Dec 23, 2009 · 1eb9acb · 1eb9acb
1 parent 3cd657f
commit 1eb9acb
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/com/github/icylisper/rabbitmq.clj b/src/com/github/icylisper/rabbitmq.clj
@@ -38,10 +38,10 @@
 
     [conn (.createChannel conn)]))
 
-(defn bind-channel [{:keys [exchange type queue routing-key]}
+(defn bind-channel [{:keys [exchange type queue routing-key durable]}
                     #^Channel ch]
-  (.exchangeDeclare ch exchange type)
-  (.queueDeclare ch queue)
+  (.exchangeDeclare ch exchange type durable)
+  (.queueDeclare ch queue durable)
   (.queueBind ch queue exchange routing-key))
 
 (defn publish [{:keys [exchange routing-key]}