blob: 22082cc82afe6efd6d680d202ca379a9c2213172 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
using System;
using System.Collections.Generic;
using System.Net;
using Autofac.Builder;
using common;
using Rhino.Queues;
namespace server
{
class Server
{
static void Main()
{
try
{
AppDomain.CurrentDomain.UnhandledException += (o, e) =>
{
(e.ExceptionObject as Exception).add_to_log();
};
AppDomain.CurrentDomain.ProcessExit += (o, e) =>
{
"shutting down".log();
try
{
Resolve.the<CommandProcessor>().stop();
Resolve.the<IQueueManager>().Dispose();
}
catch {}
Environment.Exit(Environment.ExitCode);
};
run();
Console.ReadLine();
}
catch (Exception e)
{
e.add_to_log();
Console.Out.WriteLine(e);
Console.ReadLine();
}
}
static void run()
{
var builder = new ContainerBuilder();
var registry = new AutofacDependencyRegistryBuilder(builder).build();
Resolve.initialize_with(registry);
builder.Register(x => registry).As<DependencyRegistry>().SingletonScoped();
builder.Register<StartServiceBus>().As<NeedStartup>();
var manager = new QueueManager(new IPEndPoint(IPAddress.Loopback, 2200), "server.esent");
manager.CreateQueues("server");
builder.Register(x => new RhinoPublisher("client", 2201, manager)).As<ServiceBus>().SingletonScoped();
builder.Register(x => new RhinoReceiver(manager.GetQueue("server"), x.Resolve<CommandProcessor>())).As<RhinoReceiver>().As<Receiver>().SingletonScoped();
//builder.Register<AsynchronousCommandProcessor>().As<CommandProcessor>().SingletonScoped();
builder.Register<SynchronousCommandProcessor>().As<CommandProcessor>().SingletonScoped();
builder.Register<RequestHandler>().As<Handler>();
Resolve.the<IEnumerable<NeedStartup>>().each(x => x.run());
Resolve.the<CommandProcessor>().run();
}
}
}
|
