Use amq.direct instead of "" exchange

Author: Emile Joubert

projects/wcf/RabbitMQ.ServiceModel/src/serviceModel/RabbitMQChannelBase.cs

@@ -192,6 +192,10 @@ protected BindingContext Context
             get { return m_context; }
         }
 
+        protected String Exchange
+        {
+            get { return "amq.direct"; }
+        }
 
         public event EventHandler Closed;
 

projects/wcf/RabbitMQ.ServiceModel/src/serviceModel/RabbitMQInputChannel.cs

@@ -169,7 +169,7 @@ public override void Open(TimeSpan timeout)
 #endif
             //Create a queue for messages destined to this service, bind it to the service URI routing key
             string queue = m_model.QueueDeclare();
-            m_model.QueueBind(queue, base.LocalAddress.Uri.Host, base.LocalAddress.Uri.PathAndQuery, false, null);
+            m_model.QueueBind(queue, Exchange, base.LocalAddress.Uri.PathAndQuery, false, null);
 
             //Listen to the queue
             m_messageQueue = new QueueingBasicConsumer(m_model);

projects/wcf/RabbitMQ.ServiceModel/src/serviceModel/RabbitMQOutputChannel.cs

@@ -103,7 +103,7 @@ public override void Send(Message message, TimeSpan timeout)
                     body.Length,
                     message.Headers.Action.Remove(0, message.Headers.Action.LastIndexOf('/')));
 #endif
-                m_model.BasicPublish(base.RemoteAddress.Uri.Host,
+                m_model.BasicPublish(Exchange,
                                    base.RemoteAddress.Uri.PathAndQuery,
                                    null,
                                    body);