Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- IModel channel=null;
- ConnectionFactory factory = new ConnectionFactory ();
- factory.HostName = "192.168.68.4";
- _QueueName = "172.16.1.1";
- factory.UserName = "guest";
- factory.Password = "guest";
- factory.VirtualHost = "/";
- factory.RequestedHeartbeat = 30;
- if (factory.Endpoint == null) {
- Console.WriteLine (" factory.Endpoint==null ");
- }
- // 接受消息的队列名称是本地的IP地址
- _QueueName = "172.16.1.1";
- _RMQConnection = factory.CreateConnection ();
- Console.WriteLine ("factory.CreateConnection()");
- channel = _RMQConnection.CreateModel ();
- channel.QueueDeclare(_QueueName, false, false,false,null);
Add Comment
Please, Sign In to add comment