using Rhea.Common;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using Tiger.IBusiness;
|
|
namespace Tiger.Business
|
{
|
/// <summary>
|
/// 监控总控
|
/// </summary>
|
public class MonitorBus : IMonitorBus
|
{
|
public static TransactionMonitor WMSTransactionMonitor = new();
|
public static ClientMonitor ClientMonitor = new();
|
public static DbMonitor DbMonitor = new();
|
#region Functions
|
public IClientMonitor GetClientMonitor() => ClientMonitor;
|
public void StartMonitors()
|
{
|
//开启WMS事务监控
|
WMSTransactionMonitor.Start();
|
ConsoleExt.WriteLine("Start Transaction Monitoring Thread..........", ConsoleColor.Yellow);
|
//开启DB监控
|
DbMonitor.Start();
|
ConsoleExt.WriteLine("Start Db Monitoring Thread..........", ConsoleColor.Yellow);
|
//开启客户端监控
|
ClientMonitor.Start();
|
ConsoleExt.WriteLine("Start Client Monitoring Thread..........", ConsoleColor.Yellow);
|
}
|
|
public void StopMonitors()
|
{
|
//关闭WMS事务监控
|
WMSTransactionMonitor.Stop();
|
//关闭DB监控
|
DbMonitor.Stop();
|
//关闭客户端监控
|
ClientMonitor.Stop();
|
}
|
#endregion
|
}
|
}
|
