From 6db288304fd93521c0e20455f4b0bd98ecc3db90 Mon Sep 17 00:00:00 2001
From: lixiaojun <1287241240@qq.com>
Date: 星期四, 22 八月 2024 12:46:04 +0800
Subject: [PATCH] 引用升级
---
Yw.Service.Run.Core/07-service/00-core/01-create/QueueCreateHelper.cs | 26 +++++++++++++++++++++++---
1 files changed, 23 insertions(+), 3 deletions(-)
diff --git a/Yw.Service.Run.Core/07-service/00-core/01-create/QueueCreateHelper.cs b/Yw.Service.Run.Core/07-service/00-core/01-create/QueueCreateHelper.cs
index 7c245f9..740e033 100644
--- a/Yw.Service.Run.Core/07-service/00-core/01-create/QueueCreateHelper.cs
+++ b/Yw.Service.Run.Core/07-service/00-core/01-create/QueueCreateHelper.cs
@@ -6,15 +6,35 @@
internal class QueueCreateHelper
{
/// <summary>
- /// 鍒涘缓Queue
+ /// 鍒涘缓Queue(鏃犵紦瀛�)
/// </summary>
public static T CreateQueue<T>()
{
- var queueType = Settings.RunParasHelper.Run.Queue.QueueType;
+ var dbType = Settings.RunParasHelper.Run.Queue.QueueType;
+ return Yw.QueueFactory.CreateQueue<T>(dbType);
+ }
+
+ /// <summary>
+ /// 鍒涘缓Queue(鍐呴儴缂撳瓨)
+ /// </summary>
+ public static T CreateQueue2<T>()
+ {
+ var dbType = Settings.RunParasHelper.Run.Queue.QueueType;
+ var enableCache = Settings.RunParasHelper.Run.Queue.Factory.EnableCache;
+ return Yw.QueueFactory.CreateQueue2<T>(dbType, enableCache);
+ }
+
+ /// <summary>
+ /// 鍒涘缓Queue(MemoryCache缂撳瓨)
+ /// </summary>
+ public static T CreateQueue3<T>()
+ {
+ var dbType = Settings.RunParasHelper.Run.Queue.QueueType;
var enableCache = Settings.RunParasHelper.Run.Queue.Factory.EnableCache;
var cacheTime = Settings.RunParasHelper.Run.Queue.Factory.CacheTime;
- return Yw.QueueFactory.CreateQueue<T>(queueType, enableCache, cacheTime);
+ return Yw.QueueFactory.CreateQueue3<T>(dbType, enableCache, cacheTime);
}
+
}
}
--
Gitblit v1.9.3