Skip to content

Commit d7ecd0f

Browse files
committed
Ran dotnet format
1 parent d96b16c commit d7ecd0f

File tree

9 files changed

+623
-627
lines changed

9 files changed

+623
-627
lines changed

.editorconfig

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -42,10 +42,10 @@ csharp_indent_labels = one_less_than_current
4242
csharp_preferred_modifier_order = public,private,protected,internal,file,static,extern,new,virtual,abstract,sealed,override,readonly,unsafe,required,volatile,async:suggestion
4343

4444
# avoid this. unless absolutely necessary
45-
dotnet_style_qualification_for_field = false:suggestion
46-
dotnet_style_qualification_for_property = false:suggestion
47-
dotnet_style_qualification_for_method = false:suggestion
48-
dotnet_style_qualification_for_event = false:suggestion
45+
dotnet_style_qualification_for_field = false:error
46+
dotnet_style_qualification_for_property = false:error
47+
dotnet_style_qualification_for_method = false:error
48+
dotnet_style_qualification_for_event = false:error
4949

5050
# Types: use keywords instead of BCL types, and permit var only when the type is clear
5151
csharp_style_var_for_built_in_types = false:suggestion
@@ -154,6 +154,10 @@ csharp_space_between_method_declaration_parameter_list_parentheses = false
154154
csharp_space_between_parentheses = false
155155
csharp_space_between_square_brackets = false
156156

157+
# Custom
158+
csharp_style_namespace_declarations = file_scoped:error
159+
dotnet_diagnostic.IDE0005.severity = error # Using directive is unnecessary.
160+
157161
# C++ Files
158162
[*.{cpp,h,in}]
159163
curly_bracket_next_line = true
Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
1-
namespace Foundatio.RabbitMQ
1+
namespace Foundatio.RabbitMQ;
2+
3+
public class MyMessage
24
{
3-
public class MyMessage
4-
{
5-
public string Hey { get; set; }
6-
}
5+
public string Hey { get; set; }
76
}

samples/Foundatio.RabbitMQ.Publish/Program.cs

Lines changed: 15 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -2,24 +2,23 @@
22
using System.Threading.Tasks;
33
using Foundatio.Messaging;
44

5-
namespace Foundatio.RabbitMQ.Publish
5+
namespace Foundatio.RabbitMQ.Publish;
6+
7+
public class Program
68
{
7-
public class Program
9+
public static async Task Main()
810
{
9-
public static async Task Main()
10-
{
11-
Console.WriteLine("Enter the message and press enter to send:");
11+
Console.WriteLine("Enter the message and press enter to send:");
1212

13-
using var messageBus = new RabbitMQMessageBus(new RabbitMQMessageBusOptions { ConnectionString = "amqp://localhost:5672" });
14-
string message;
15-
do
16-
{
17-
message = Console.ReadLine();
18-
var delay = TimeSpan.FromSeconds(1);
19-
var body = new MyMessage { Hey = message };
20-
await messageBus.PublishAsync(body, delay);
21-
Console.WriteLine("Message sent. Enter new message or press enter to exit:");
22-
} while (!String.IsNullOrEmpty(message));
23-
}
13+
using var messageBus = new RabbitMQMessageBus(new RabbitMQMessageBusOptions { ConnectionString = "amqp://localhost:5672" });
14+
string message;
15+
do
16+
{
17+
message = Console.ReadLine();
18+
var delay = TimeSpan.FromSeconds(1);
19+
var body = new MyMessage { Hey = message };
20+
await messageBus.PublishAsync(body, delay);
21+
Console.WriteLine("Message sent. Enter new message or press enter to exit:");
22+
} while (!String.IsNullOrEmpty(message));
2423
}
2524
}

samples/Foundatio.RabbitMQ.Subscribe/Program.cs

Lines changed: 16 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -3,26 +3,25 @@
33
using System.Threading.Tasks;
44
using Foundatio.Messaging;
55

6-
namespace Foundatio.RabbitMQ.Subscribe
6+
namespace Foundatio.RabbitMQ.Subscribe;
7+
8+
public class Program
79
{
8-
public class Program
10+
public static async Task Main(string[] args)
911
{
10-
public static async Task Main(string[] args)
11-
{
12-
Console.WriteLine("Waiting to receive messages, press enter to quit...");
12+
Console.WriteLine("Waiting to receive messages, press enter to quit...");
1313

14-
var tasks = new List<Task>();
15-
var messageBuses = new List<IMessageBus>();
16-
for (int i = 0; i < 3; i++)
17-
{
18-
var messageBus = new RabbitMQMessageBus(new RabbitMQMessageBusOptions { ConnectionString = "amqp://localhost:5672" });
19-
messageBuses.Add(messageBus);
20-
tasks.Add(messageBus.SubscribeAsync<MyMessage>(msg => { Console.WriteLine($"Got subscriber {messageBus.MessageBusId} message: {msg.Hey}"); }));
21-
}
22-
await Task.WhenAll(tasks);
23-
Console.ReadLine();
24-
foreach (var messageBus in messageBuses)
25-
messageBus.Dispose();
14+
var tasks = new List<Task>();
15+
var messageBuses = new List<IMessageBus>();
16+
for (int i = 0; i < 3; i++)
17+
{
18+
var messageBus = new RabbitMQMessageBus(new RabbitMQMessageBusOptions { ConnectionString = "amqp://localhost:5672" });
19+
messageBuses.Add(messageBus);
20+
tasks.Add(messageBus.SubscribeAsync<MyMessage>(msg => { Console.WriteLine($"Got subscriber {messageBus.MessageBusId} message: {msg.Hey}"); }));
2621
}
22+
await Task.WhenAll(tasks);
23+
Console.ReadLine();
24+
foreach (var messageBus in messageBuses)
25+
messageBus.Dispose();
2726
}
2827
}

src/Foundatio.RabbitMQ/Extensions/TaskExtensions.cs

Lines changed: 16 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -4,26 +4,25 @@
44
using System.Threading.Tasks;
55
using Foundatio.AsyncEx;
66

7-
namespace Foundatio.Extensions
7+
namespace Foundatio.Extensions;
8+
9+
internal static class TaskExtensions
810
{
9-
internal static class TaskExtensions
11+
[DebuggerStepThrough]
12+
public static ConfiguredTaskAwaitable<TResult> AnyContext<TResult>(this Task<TResult> task)
1013
{
11-
[DebuggerStepThrough]
12-
public static ConfiguredTaskAwaitable<TResult> AnyContext<TResult>(this Task<TResult> task)
13-
{
14-
return task.ConfigureAwait(continueOnCapturedContext: false);
15-
}
14+
return task.ConfigureAwait(continueOnCapturedContext: false);
15+
}
1616

17-
[DebuggerStepThrough]
18-
public static ConfiguredTaskAwaitable AnyContext(this Task task)
19-
{
20-
return task.ConfigureAwait(continueOnCapturedContext: false);
21-
}
17+
[DebuggerStepThrough]
18+
public static ConfiguredTaskAwaitable AnyContext(this Task task)
19+
{
20+
return task.ConfigureAwait(continueOnCapturedContext: false);
21+
}
2222

23-
[DebuggerStepThrough]
24-
public static ConfiguredTaskAwaitable<TResult> AnyContext<TResult>(this AwaitableDisposable<TResult> task) where TResult : IDisposable
25-
{
26-
return task.ConfigureAwait(continueOnCapturedContext: false);
27-
}
23+
[DebuggerStepThrough]
24+
public static ConfiguredTaskAwaitable<TResult> AnyContext<TResult>(this AwaitableDisposable<TResult> task) where TResult : IDisposable
25+
{
26+
return task.ConfigureAwait(continueOnCapturedContext: false);
2827
}
2928
}
Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,7 @@
1-
namespace Foundatio.Messaging
1+
namespace Foundatio.Messaging;
2+
3+
public enum AcknowledgementStrategy
24
{
3-
public enum AcknowledgementStrategy
4-
{
5-
FireAndForget,
6-
Automatic
7-
}
5+
FireAndForget,
6+
Automatic
87
}

0 commit comments

Comments
 (0)