|
@@ -136,7 +136,8 @@ namespace MySystem
|
|
|
UserName = UserName,
|
|
UserName = UserName,
|
|
|
Password = Password,
|
|
Password = Password,
|
|
|
AutomaticRecoveryEnabled = true, //如果connection挂掉是否重新连接
|
|
AutomaticRecoveryEnabled = true, //如果connection挂掉是否重新连接
|
|
|
- TopologyRecoveryEnabled = true //连接恢复后,连接的交换机,队列等是否一同恢复
|
|
|
|
|
|
|
+ TopologyRecoveryEnabled = true, //连接恢复后,连接的交换机,队列等是否一同恢复
|
|
|
|
|
+ VirtualHost = VirtualHostName,
|
|
|
};
|
|
};
|
|
|
List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
|
|
List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
|
|
|
string[] HostNames = HostName.Split(',');
|
|
string[] HostNames = HostName.Split(',');
|