using CSRedis;
|
using Furion;
|
using InitQ;
|
using Mapster;
|
using Microsoft.AspNetCore.Builder;
|
using Microsoft.AspNetCore.Hosting;
|
using Microsoft.Extensions.Configuration;
|
using Microsoft.Extensions.DependencyInjection;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Reflection;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace DocumentServiceApi.InitQMessage
|
{
|
/// <summary>
|
/// 注册 INITQ
|
/// </summary>
|
|
public class DocServiceINITQStartup : AppStartup
|
{
|
public void ConfigureServices(IServiceCollection services) {
|
|
|
var readisconnectionstring = App.Configuration["InitQRedisConfig:ConnectionString"];
|
if (readisconnectionstring != null)
|
//初始化redi配置
|
{
|
services.AddInitQ((op) =>
|
{
|
op.SuspendTime = 500;
|
op.IntervalTime = 500;
|
op.ConnectionString = readisconnectionstring;
|
op.ListSubscribe = new List<Type>() { typeof(MessageReceive) };
|
op.ShowLog = false;
|
});
|
}
|
|
}
|
|
public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
|
{
|
|
|
}
|
}
|
}
|
