using System.Threading.Tasks;
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.Loging;
|
using InitQ.Abstractions;
|
using InitQ.Attributes;
|
using NLog;
|
|
namespace CoreCms.Net.RedisMQ
|
{
|
public class DemoSubscribe : IRedisSubscribe
|
{
|
|
[Subscribe(RedisMessageQueueKey.Loging)]
|
private async Task SubRedisOrder2(string msg)
|
{
|
NLogUtil.WriteDbLog(LogLevel.Debug, LogType.RedisMessageQueue, "消息队列", $"接口端订阅从队列{RedisMessageQueueKey.Loging} 接受到 消息:{msg}");
|
|
await Task.CompletedTask;
|
}
|
|
|
[Subscribe(RedisMessageQueueKey.SmsQueue)]
|
private async Task SubSmsQueue1(string msg)
|
{
|
NLogUtil.WriteDbLog(LogLevel.Debug, LogType.RedisMessageQueue, "消息队列", $"接口端订阅从队列{RedisMessageQueueKey.SmsQueue} 接受到 消息:{msg}");
|
|
await Task.CompletedTask;
|
}
|
|
}
|
}
|
