Message Bus

phongnguyend · phongnguyend · commit 346eb08273dd · 2023-09-06T06:45:52.000+07:00
diff --git a/src/Microservices/Common/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBus.cs b/src/Microservices/Common/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBus.cs
@@ -7,8 +7,20 @@ namespace ClassifiedAds.Domain.Infrastructure.MessageBrokers;
 public interface IMessageBus
 {
     Task SendAsync<T>(T message, MetaData metaData = null, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent;
+        where T : IMessageBusMessage;
 
     Task ReceiveAsync<TConsumer, T>(Func<T, MetaData, Task> action, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent;
+        where T : IMessageBusMessage;
 }
+
+public interface IMessageBusMessage
+{
+}
+
+public interface IMessageBusEvent : IMessageBusMessage
+{
+}
+
+public interface IMessageBusCommand : IMessageBusMessage
+{
+}
diff --git a/src/Microservices/Common/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBusEvent.cs b/src/Microservices/Common/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBusEvent.cs
diff --git a/src/Microservices/Common/ClassifiedAds.Domain/Infrastructure/MessageBrokers/MessageBus.cs b/src/Microservices/Common/ClassifiedAds.Domain/Infrastructure/MessageBrokers/MessageBus.cs
@@ -15,13 +15,13 @@ public MessageBus(IServiceProvider serviceProvider)
     }
 
     public async Task SendAsync<T>(T message, MetaData metaData = null, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent
+        where T : IMessageBusMessage
     {
         await _serviceProvider.GetRequiredService<IMessageSender<T>>().SendAsync(message, metaData, cancellationToken);
     }
 
     public async Task ReceiveAsync<TConsumer, T>(Func<T, MetaData, Task> action, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent
+        where T : IMessageBusMessage
     {
         await _serviceProvider.GetRequiredService<IMessageReceiver<TConsumer, T>>().ReceiveAsync(action, cancellationToken);
     }
diff --git a/src/ModularMonolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBus.cs b/src/ModularMonolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBus.cs
@@ -7,8 +7,20 @@ namespace ClassifiedAds.Domain.Infrastructure.MessageBrokers;
 public interface IMessageBus
 {
     Task SendAsync<T>(T message, MetaData metaData = null, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent;
+        where T : IMessageBusMessage;
 
     Task ReceiveAsync<TConsumer, T>(Func<T, MetaData, Task> action, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent;
+        where T : IMessageBusMessage;
 }
+
+public interface IMessageBusMessage
+{
+}
+
+public interface IMessageBusEvent : IMessageBusMessage
+{
+}
+
+public interface IMessageBusCommand : IMessageBusMessage
+{
+}
diff --git a/src/ModularMonolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBusEvent.cs b/src/ModularMonolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBusEvent.cs
diff --git a/src/ModularMonolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/MessageBus.cs b/src/ModularMonolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/MessageBus.cs
@@ -15,13 +15,13 @@ public MessageBus(IServiceProvider serviceProvider)
     }
 
     public async Task SendAsync<T>(T message, MetaData metaData = null, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent
+        where T : IMessageBusMessage
     {
         await _serviceProvider.GetRequiredService<IMessageSender<T>>().SendAsync(message, metaData, cancellationToken);
     }
 
     public async Task ReceiveAsync<TConsumer, T>(Func<T, MetaData, Task> action, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent
+        where T : IMessageBusMessage
     {
         await _serviceProvider.GetRequiredService<IMessageReceiver<TConsumer, T>>().ReceiveAsync(action, cancellationToken);
     }
diff --git a/src/Monolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBus.cs b/src/Monolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBus.cs
@@ -7,8 +7,20 @@ namespace ClassifiedAds.Domain.Infrastructure.MessageBrokers;
 public interface IMessageBus
 {
     Task SendAsync<T>(T message, MetaData metaData = null, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent;
+        where T : IMessageBusMessage;
 
     Task ReceiveAsync<TConsumer, T>(Func<T, MetaData, Task> action, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent;
+        where T : IMessageBusMessage;
 }
+
+public interface IMessageBusMessage
+{
+}
+
+public interface IMessageBusEvent : IMessageBusMessage
+{
+}
+
+public interface IMessageBusCommand : IMessageBusMessage
+{
+}
diff --git a/src/Monolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBusEvent.cs b/src/Monolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/IMessageBusEvent.cs
diff --git a/src/Monolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/MessageBus.cs b/src/Monolith/ClassifiedAds.Domain/Infrastructure/MessageBrokers/MessageBus.cs
@@ -15,13 +15,13 @@ public MessageBus(IServiceProvider serviceProvider)
     }
 
     public async Task SendAsync<T>(T message, MetaData metaData = null, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent
+        where T : IMessageBusMessage
     {
         await _serviceProvider.GetRequiredService<IMessageSender<T>>().SendAsync(message, metaData, cancellationToken);
     }
 
     public async Task ReceiveAsync<TConsumer, T>(Func<T, MetaData, Task> action, CancellationToken cancellationToken = default)
-        where T : IMessageBusEvent
+        where T : IMessageBusMessage
     {
         await _serviceProvider.GetRequiredService<IMessageReceiver<TConsumer, T>>().ReceiveAsync(action, cancellationToken);
     }

Original file line number	Diff line number	Diff line change
`@@ -15,13 +15,13 @@ public MessageBus(IServiceProvider serviceProvider)`
`15`	`15`	`}`
`16`	`16`
`17`	`17`	`public async Task SendAsync<T>(T message, MetaData metaData = null, CancellationToken cancellationToken = default)`
`18`		`- where T : IMessageBusEvent`
	`18`	`+ where T : IMessageBusMessage`
`19`	`19`	`{`
`20`	`20`	`await _serviceProvider.GetRequiredService<IMessageSender<T>>().SendAsync(message, metaData, cancellationToken);`
`21`	`21`	`}`
`22`	`22`
`23`	`23`	`public async Task ReceiveAsync<TConsumer, T>(Func<T, MetaData, Task> action, CancellationToken cancellationToken = default)`
`24`		`- where T : IMessageBusEvent`
	`24`	`+ where T : IMessageBusMessage`
`25`	`25`	`{`
`26`	`26`	`await _serviceProvider.GetRequiredService<IMessageReceiver<TConsumer, T>>().ReceiveAsync(action, cancellationToken);`
`27`	`27`	`}`