using EasyNetQ;
|
/********************************************************************************
|
|
** auth： DBS
|
|
** date： 2018/11/14 22:02:14
|
|
** desc： 尚未编写描述
|
|
** Ver.: V1.0.0
|
|
*********************************************************************************/
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WMS.Common.RabbitMQ
|
{
|
/// <summary>
|
/// 消息服务器连接器
|
/// </summary>
|
public class BusBuilder
|
{
|
public static IBus CreateMessageBus()
|
{
|
// 消息服务器连接字符串
|
// var connectionString = ConfigurationManager.ConnectionStrings["RabbitMQ"];
|
string connString = "host=192.168.1.198:5672;virtualHost=OrderQueue;username=hh;password=123456";
|
if (connString == null || connString == string.Empty)
|
{
|
throw new Exception("messageserver connection string is missing or empty");
|
}
|
|
return RabbitHutch.CreateBus(connString);
|
}
|
}
|
}
|
