Do not attempt to redeclare tmp quue's which are declared exclusive.

ServiceStack · Nov 5, 2014 · 5ddf12b · 5ddf12b
1 parent 8e47be0
commit 5ddf12b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/ServiceStack.RabbitMq/RabbitMqExtensions.cs b/src/ServiceStack.RabbitMq/RabbitMqExtensions.cs
@@ -155,7 +155,9 @@ public static bool IsServerNamedQueue(this string queueName)
                 throw new ArgumentNullException("queueName");
             }
 
-            return queueName.ToLower().StartsWith("amq.");
+            var lowerCaseQueue = queueName.ToLower();
+            return lowerCaseQueue.StartsWith("amq.")
+                || lowerCaseQueue.StartsWith(QueueNames.TempMqPrefix);
         }	
 
         public static void PopulateFromMessage(this IBasicProperties props, IMessage message)

diff --git a/src/ServiceStack.RabbitMq/RabbitMqProducer.cs b/src/ServiceStack.RabbitMq/RabbitMqProducer.cs
@@ -115,7 +115,8 @@ public void PublishMessage(string exchange, string routingKey, IBasicProperties
         {
             try
             {
-                // In case of server named queues (client declared queue with channel.declare()), assume queue already exists (redeclaration would result in error anyway since queue was marked as exclusive) and publish to default exchange
+                // In case of server named queues (client declared queue with channel.declare()), assume queue already exists 
+                //(redeclaration would result in error anyway since queue was marked as exclusive) and publish to default exchange
                 if (routingKey.IsServerNamedQueue()) 
                 {
                     Channel.BasicPublish("", routingKey, basicProperties, body);