Khwezi Mngoma
acc0d44c7c
Internal service bus support enabled Added quartz support Reconfigured extensions
23 lines
636 B
C#
23 lines
636 B
C#
using LiteCharms.Abstractions;
|
|
using LiteCharms.Infrastructure.ServiceBus.Queues;
|
|
|
|
namespace LiteCharms.Infrastructure.ServiceBus;
|
|
|
|
public class GeneralServiceBus(GeneralQueue messages) : IEventBus
|
|
{
|
|
public async Task<Result> PublishAsync<TEvent>(TEvent notification, CancellationToken cancellationToken = default)
|
|
where TEvent : class, IEvent
|
|
{
|
|
try
|
|
{
|
|
await messages.Outgoing.WriteAsync(notification, cancellationToken);
|
|
|
|
return Result.Ok();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return Result.Fail(new Error(ex.Message).CausedBy(ex));
|
|
}
|
|
}
|
|
}
|