Skip to content

Commit aa90b81

Browse files
mythzmythz
committed
to file scoped namespaces
1 parent ccaa883 commit aa90b81

File tree

5 files changed

+79
-88
lines changed

5 files changed

+79
-88
lines changed

‎mq/backgroundmq/Configure.Mq.cs

+15-16
Original file line numberDiff line numberDiff line change
@@ -5,21 +5,20 @@
55

66
[assembly: HostingStartup(typeof(MyApp.ConfigureMq))]
77

8-
namespace MyApp
8+
namespace MyApp;
9+
10+
/**
11+
Register Services you want available via MQ in your AppHost, e.g:
12+
var mqServer = appHost.Resolve<IMessageService>();
13+
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
14+
*/
15+
public class ConfigureMq : IHostingStartup
916
{
10-
/**
11-
Register Services you want available via MQ in your AppHost, e.g:
12-
var mqServer = appHost.Resolve<IMessageService>();
13-
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
14-
*/
15-
public class ConfigureMq : IHostingStartup
16-
{
17-
public void Configure(IWebHostBuilder builder) => builder
18-
.ConfigureServices(services => {
19-
services.AddSingleton<IMessageService>(c => new BackgroundMqService());
20-
})
21-
.ConfigureAppHost(afterAppHostInit: appHost => {
22-
appHost.Resolve<IMessageService>().Start();
23-
});
24-
}
17+
public void Configure(IWebHostBuilder builder) => builder
18+
.ConfigureServices(services => {
19+
services.AddSingleton<IMessageService>(c => new BackgroundMqService());
20+
})
21+
.ConfigureAppHost(afterAppHostInit: appHost => {
22+
appHost.Resolve<IMessageService>().Start();
23+
});
2524
}

‎mq/rabbitmq/Configure.Mq.cs

+15-17
Original file line numberDiff line numberDiff line change
@@ -6,22 +6,20 @@
66

77
[assembly: HostingStartup(typeof(MyApp.ConfigureMq))]
88

9-
namespace MyApp
9+
namespace MyApp;
10+
/**
11+
Register Services you want available via MQ in your AppHost, e.g:
12+
var mqServer = appHost.Resolve<IMessageService>();
13+
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
14+
*/
15+
public class ConfigureMq : IHostingStartup
1016
{
11-
/**
12-
Register Services you want available via MQ in your AppHost, e.g:
13-
var mqServer = appHost.Resolve<IMessageService>();
14-
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
15-
*/
16-
public class ConfigureMq : IHostingStartup
17-
{
18-
public void Configure(IWebHostBuilder builder) => builder
19-
.ConfigureServices((context, services) => {
20-
services.AddSingleton<IMessageService>(c =>
21-
new RabbitMqServer(context.Configuration.GetConnectionString("RabbitMq") ?? "localhost:5672"));
22-
})
23-
.ConfigureAppHost(afterAppHostInit: appHost => {
24-
appHost.Resolve<IMessageService>().Start();
25-
});
26-
}
17+
public void Configure(IWebHostBuilder builder) => builder
18+
.ConfigureServices((context, services) => {
19+
services.AddSingleton<IMessageService>(c =>
20+
new RabbitMqServer(context.Configuration.GetConnectionString("RabbitMq") ?? "localhost:5672"));
21+
})
22+
.ConfigureAppHost(afterAppHostInit: appHost => {
23+
appHost.Resolve<IMessageService>().Start();
24+
});
2725
}

‎mq/redismq/Configure.Mq.cs

+15-17
Original file line numberDiff line numberDiff line change
@@ -7,22 +7,20 @@
77

88
[assembly: HostingStartup(typeof(MyApp.ConfigureMq))]
99

10-
namespace MyApp
10+
namespace MyApp;
11+
/**
12+
Register Services you want available via MQ in your AppHost, e.g:
13+
var mqServer = appHost.Resolve<IMessageService>();
14+
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
15+
*/
16+
public class ConfigureMq : IHostingStartup
1117
{
12-
/**
13-
Register Services you want available via MQ in your AppHost, e.g:
14-
var mqServer = appHost.Resolve<IMessageService>();
15-
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
16-
*/
17-
public class ConfigureMq : IHostingStartup
18-
{
19-
public void Configure(IWebHostBuilder builder) => builder
20-
.ConfigureServices((context, services) => {
21-
services.AddSingleton<IMessageService>(c =>
22-
new RedisMqServer(c.Resolve<IRedisClientsManager>()));
23-
})
24-
.ConfigureAppHost(afterAppHostInit: appHost => {
25-
appHost.Resolve<IMessageService>().Start();
26-
});
27-
}
18+
public void Configure(IWebHostBuilder builder) => builder
19+
.ConfigureServices((context, services) => {
20+
services.AddSingleton<IMessageService>(c =>
21+
new RedisMqServer(c.Resolve<IRedisClientsManager>()));
22+
})
23+
.ConfigureAppHost(afterAppHostInit: appHost => {
24+
appHost.Resolve<IMessageService>().Start();
25+
});
2826
}

‎mq/servicebus/Configure.Mq.cs

+15-17
Original file line numberDiff line numberDiff line change
@@ -7,22 +7,20 @@
77

88
[assembly: HostingStartup(typeof(MyApp.ConfigureMq))]
99

10-
namespace MyApp
10+
namespace MyApp;
11+
/**
12+
Register Services you want available via MQ in your AppHost, e.g:
13+
var mqServer = appHost.Resolve<IMessageService>();
14+
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
15+
*/
16+
public class ConfigureMq : IHostingStartup
1117
{
12-
/**
13-
Register Services you want available via MQ in your AppHost, e.g:
14-
var mqServer = appHost.Resolve<IMessageService>();
15-
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
16-
*/
17-
public class ConfigureMq : IHostingStartup
18-
{
19-
public void Configure(IWebHostBuilder builder) => builder
20-
.ConfigureServices((context, services) => {
21-
services.AddSingleton<IMessageService>(c =>
22-
new ServiceBusMqServer(context.Configuration.GetConnectionString("ServiceBus")));
23-
})
24-
.ConfigureAppHost(afterAppHostInit: appHost => {
25-
appHost.Resolve<IMessageService>().Start();
26-
});
27-
}
18+
public void Configure(IWebHostBuilder builder) => builder
19+
.ConfigureServices((context, services) => {
20+
services.AddSingleton<IMessageService>(c =>
21+
new ServiceBusMqServer(context.Configuration.GetConnectionString("ServiceBus")));
22+
})
23+
.ConfigureAppHost(afterAppHostInit: appHost => {
24+
appHost.Resolve<IMessageService>().Start();
25+
});
2826
}

‎mq/sqs/Configure.Mq.cs

+19-21
Original file line numberDiff line numberDiff line change
@@ -7,27 +7,25 @@
77

88
[assembly: HostingStartup(typeof(MyApp.ConfigureMq))]
99

10-
namespace MyApp
10+
namespace MyApp;
11+
/**
12+
Register Services you want available via MQ in your AppHost, e.g:
13+
var mqServer = appHost.Resolve<IMessageService>();
14+
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
15+
*/
16+
public class ConfigureMq : IHostingStartup
1117
{
12-
/**
13-
Register Services you want available via MQ in your AppHost, e.g:
14-
var mqServer = appHost.Resolve<IMessageService>();
15-
mqServer.RegisterHandler<MyRequest>(ExecuteMessage);
16-
*/
17-
public class ConfigureMq : IHostingStartup
18-
{
19-
public void Configure(IWebHostBuilder builder) => builder
20-
.ConfigureServices((context, services) => {
21-
services.AddSingleton<IMessageService>(c => new SqsMqServer(
22-
context.Configuration["AwsAccessKey"],
23-
context.Configuration["AwsSecretKey"],
24-
RegionEndpoint.USEast1)
25-
{
26-
DisableBuffering = true, // Trade-off latency vs efficiency
27-
});
28-
})
29-
.ConfigureAppHost(afterAppHostInit: appHost => {
30-
appHost.Resolve<IMessageService>().Start();
18+
public void Configure(IWebHostBuilder builder) => builder
19+
.ConfigureServices((context, services) => {
20+
services.AddSingleton<IMessageService>(c => new SqsMqServer(
21+
context.Configuration["AwsAccessKey"],
22+
context.Configuration["AwsSecretKey"],
23+
RegionEndpoint.USEast1)
24+
{
25+
DisableBuffering = true, // Trade-off latency vs efficiency
3126
});
32-
}
27+
})
28+
.ConfigureAppHost(afterAppHostInit: appHost => {
29+
appHost.Resolve<IMessageService>().Start();
30+
});
3331
}

0 commit comments

Comments
 (0)