|
@@ -11,12 +11,13 @@ namespace MySystem
|
|
|
public class RabbitMQClient
|
|
public class RabbitMQClient
|
|
|
{
|
|
{
|
|
|
public readonly static RabbitMQClient Instance = new RabbitMQClient();
|
|
public readonly static RabbitMQClient Instance = new RabbitMQClient();
|
|
|
- string UserName,Password,HostName;
|
|
|
|
|
|
|
+ string UserName,Password,HostName,VirtualHostName;
|
|
|
private RabbitMQClient()
|
|
private RabbitMQClient()
|
|
|
{
|
|
{
|
|
|
UserName = ConfigurationManager.AppSettings["MqUserName"].ToString();
|
|
UserName = ConfigurationManager.AppSettings["MqUserName"].ToString();
|
|
|
Password = ConfigurationManager.AppSettings["MqPassword"].ToString();
|
|
Password = ConfigurationManager.AppSettings["MqPassword"].ToString();
|
|
|
HostName = ConfigurationManager.AppSettings["MqHostName"].ToString();
|
|
HostName = ConfigurationManager.AppSettings["MqHostName"].ToString();
|
|
|
|
|
+ VirtualHostName = ConfigurationManager.AppSettings["MqVirtualHostName"].ToString();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
#region 单对单发送
|
|
#region 单对单发送
|
|
@@ -118,6 +119,7 @@ namespace MySystem
|
|
|
AutomaticRecoveryEnabled = true, //如果connection挂掉是否重新连接
|
|
AutomaticRecoveryEnabled = true, //如果connection挂掉是否重新连接
|
|
|
TopologyRecoveryEnabled = true, //连接恢复后,连接的交换机,队列等是否一同恢复
|
|
TopologyRecoveryEnabled = true, //连接恢复后,连接的交换机,队列等是否一同恢复
|
|
|
RequestedHeartbeat = TimeSpan.FromMinutes(1),
|
|
RequestedHeartbeat = TimeSpan.FromMinutes(1),
|
|
|
|
|
+ VirtualHost = VirtualHostName,
|
|
|
};
|
|
};
|
|
|
List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
|
|
List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
|
|
|
string[] HostNames = HostName.Split(',');
|
|
string[] HostNames = HostName.Split(',');
|