got to stop for now
This commit is contained in:
@@ -16,19 +16,19 @@ namespace NOCQ.Application
|
|||||||
//var s = RedisDatabase.GetNextAlert(SettingsParser.Parse(Path.Combine("settings.json").ToString()).Redis);
|
//var s = RedisDatabase.GetNextAlert(SettingsParser.Parse(Path.Combine("settings.json").ToString()).Redis);
|
||||||
|
|
||||||
// process s
|
// process s
|
||||||
var importPlugs = CatalogRepository.GetImportPlugins();
|
// var importPlugs = CatalogRepository.GetImportPlugins();
|
||||||
|
//
|
||||||
importPlugs.ToList().ForEach(x =>
|
// importPlugs.ToList().ForEach(x =>
|
||||||
{
|
// {
|
||||||
//Task.Factory.StartNew(x.Value.Run, TaskCreationOptions.LongRunning);
|
// //Task.Factory.StartNew(x.Value.Run, TaskCreationOptions.LongRunning);
|
||||||
Console.WriteLine(x.Value.Name);
|
// Console.WriteLine(x.Value.Name);
|
||||||
});
|
// });
|
||||||
|
//
|
||||||
//RedisDatabase.SaveAlert(, "127.0.0.1", RedisQueues.Output, 6379, 3000);
|
//RedisDatabase.SaveAlert(, "127.0.0.1", RedisQueues.Output, 6379, 3000);
|
||||||
|
|
||||||
// Parse the settings file
|
// Parse the settings file
|
||||||
var json = File.ReadAllText ("settings.json");
|
//var json = File.ReadAllText ("settings.json");
|
||||||
var settings = SettingsParser.Parse (json);
|
var settings = SettingsParser.Parse ();
|
||||||
|
|
||||||
// Load the settings for the email plugin
|
// Load the settings for the email plugin
|
||||||
//var email = settings.InputPlugins.Single (x => x.Name == "Email");
|
//var email = settings.InputPlugins.Single (x => x.Name == "Email");
|
||||||
|
|||||||
17
src/NOCQ/Model/ProcessContext.cs
Normal file
17
src/NOCQ/Model/ProcessContext.cs
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
using System;
|
||||||
|
using System.Dynamic;
|
||||||
|
|
||||||
|
namespace NOCQ.Model
|
||||||
|
{
|
||||||
|
public class ProcessContext
|
||||||
|
{
|
||||||
|
public Alert Alert { get; private set;}
|
||||||
|
public ExpandoObject SessionData {get; private set;}
|
||||||
|
public ProcessContext(Alert alert, ExpandoObject data)
|
||||||
|
{
|
||||||
|
Alert = alert;
|
||||||
|
SessionData = data;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@@ -73,6 +73,7 @@
|
|||||||
<Compile Include="Settings\SettingsParser.cs" />
|
<Compile Include="Settings\SettingsParser.cs" />
|
||||||
<Compile Include="DB\RedisDatabase.cs" />
|
<Compile Include="DB\RedisDatabase.cs" />
|
||||||
<Compile Include="Extensability\CatalogRepository.cs" />
|
<Compile Include="Extensability\CatalogRepository.cs" />
|
||||||
|
<Compile Include="Model\ProcessContext.cs" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
|
<Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
|
|||||||
Reference in New Issue
Block a user