[rabbitmq-discuss] How to setup dead-letter queue in C# ?

[Johan Klijn]

I am using RabbitMQ v2.8.1.

your sample is working, and I managed to declare the exchange also, using
the code below. When I specify the exchange type of Direct for the
dead-letter-exchange it is not working. That's probably the reason why it
was not working for me.


            ConnectionFactory cf = new ConnectionFactory();
            cf.HostName = "10.57.244.205";
            using (IConnection conn = cf.CreateConnection())
            {
                using (IModel ch = conn.CreateModel())
                {
                    ch.ExchangeDeclare("DeadLetterQueue2Exchange",
ExchangeType.Fanout);

                    ch.QueueDeclare("DeadLetterQueue2", true, false, false,
null);
                    ch.QueueBind("DeadLetterQueue2",
"DeadLetterQueue2Exchange", "");
                    Hashtable arguments = new Hashtable() 
                 { 
                     {"x-dead-letter-exchange", "DeadLetterQueue2Exchange"} 
                 };
                    ch.QueueDeclare("MessageQueue2", true, false, false,
arguments);
                    ch.BasicPublish("", "MessageQueue2", null, new byte[0]);
                    BasicGetResult result = ch.BasicGet("MessageQueue2",
false);
                    ch.BasicNack(result.DeliveryTag, false, false);
                }
            }



--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/How-to-setup-dead-letter-queue-in-C-tp23913p23977.html
Sent from the RabbitMQ mailing list archive at Nabble.com.