|
|
@@ -14,6 +14,9 @@ namespace YSAI.Core.subscription
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// 自定义订阅操作
|
|
|
+ /// //只支持两种数据结果的自定义订阅
|
|
|
+ /// 1.ConcurrentDictionary<string, AddressValue>
|
|
|
+ /// 2.List<ConcurrentDictionary<string, AddressValue>>
|
|
|
/// </summary>
|
|
|
public class SubscribeOperate : IBase<SubscribeData.EventParam>, ISubscribe
|
|
|
{
|
|
|
@@ -247,7 +250,7 @@ namespace YSAI.Core.subscription
|
|
|
public OperateResult Subscribe(List<AddressDetails> nodes)
|
|
|
{
|
|
|
//开始记录运行时间
|
|
|
- RunTimeTool.Instance("SubscribeOperate.Subscribe").StartRecord();
|
|
|
+ RunTimeTool.Instance($"{ClassName}.Subscribe").StartRecord();
|
|
|
try
|
|
|
{
|
|
|
GoOn = false;
|
|
|
@@ -275,7 +278,7 @@ namespace YSAI.Core.subscription
|
|
|
public OperateResult UnSubscribe(List<AddressDetails> nodes)
|
|
|
{
|
|
|
//开始记录运行时间
|
|
|
- RunTimeTool.Instance("SubscribeOperate.UnSubscribe").StartRecord();
|
|
|
+ RunTimeTool.Instance($"{ClassName}.UnSubscribe").StartRecord();
|
|
|
try
|
|
|
{
|
|
|
GoOn = false;
|
|
|
@@ -318,7 +321,7 @@ namespace YSAI.Core.subscription
|
|
|
public OperateResult On()
|
|
|
{
|
|
|
//开始记录运行时间
|
|
|
- RunTimeTool.Instance("SubscribeOperate.On").StartRecord();
|
|
|
+ RunTimeTool.Instance($"{ClassName}.On").StartRecord();
|
|
|
try
|
|
|
{
|
|
|
if (thread == null)
|
|
|
@@ -348,7 +351,7 @@ namespace YSAI.Core.subscription
|
|
|
public OperateResult Off()
|
|
|
{
|
|
|
//开始记录运行时间
|
|
|
- RunTimeTool.Instance("SubscribeOperate.Off").StartRecord();
|
|
|
+ RunTimeTool.Instance($"{ClassName}.Off").StartRecord();
|
|
|
try
|
|
|
{
|
|
|
//监控开关关闭
|