Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- using RabbitMQ.Client;
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using System.Threading.Tasks;
- namespace ConsoleApplication3{
- class Program{
- static void Main(string[] args){
- var factory = new ConnectionFactory()
- {
- UserName = "guest",
- Password = "guest",
- HostName = "localhost",
- VirtualHost = "Piotrek"
- };
- using (var connection = factory.CreateConnection())
- using (var channel = connection.CreateModel())
- {
- channel.QueueDeclare("message_queue", false, false, false, null);
- var consumer = new MyConsumer(channel);
- channel.BasicConsume("message_queue",false, consumer);
- System.Console.ReadLine();
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement