Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- amqpChannel.ExchangeDeclare("myexchange", ExchangeType.Fanout);
- var queue = amqpChannel.QueueDeclare(
- queue: "myqueue",
- durable: true,
- exclusive: false,
- autoDelete: false,
- arguments: null);
- amqpChannel.QueueBind("myqueue", "myexchange", null);
- public static void QueueBind(this IModel model, string queue, string exchange, string routingKey, IDictionary<string, object> arguments = null)
- {
- model.QueueBind(queue, exchange, routingKey, arguments);
- }
Add Comment
Please, Sign In to add comment