diff --git a/src/Tingle.EventBus.Transports.Amazon.Sqs/MessageAttributeExtensions.cs b/src/Tingle.EventBus.Transports.Amazon.Sqs/MessageAttributeExtensions.cs index e00781b1..9b6c32a5 100644 --- a/src/Tingle.EventBus.Transports.Amazon.Sqs/MessageAttributeExtensions.cs +++ b/src/Tingle.EventBus.Transports.Amazon.Sqs/MessageAttributeExtensions.cs @@ -51,7 +51,7 @@ public static PublishRequest SetAttributes(this PublishRequest request, EventCon { if (request is null) throw new ArgumentNullException(nameof(request)); static SNSAttribute creator(string v) => new() { DataType = "String", StringValue = v }; - + request.MessageAttributes.SetAttributes(creator, @event); return request; } diff --git a/src/Tingle.EventBus.Transports.InMemory/InMemoryTransport.cs b/src/Tingle.EventBus.Transports.InMemory/InMemoryTransport.cs index fd8988c7..45ae70d4 100644 --- a/src/Tingle.EventBus.Transports.InMemory/InMemoryTransport.cs +++ b/src/Tingle.EventBus.Transports.InMemory/InMemoryTransport.cs @@ -25,7 +25,7 @@ public class InMemoryTransport(IServiceScopeFactory serviceScopeFactory, IOptions busOptionsAccessor, IOptionsMonitor optionsMonitor, ILoggerFactory loggerFactory, - SequenceNumberGenerator sng) + SequenceNumberGenerator sng) : EventBusTransport(serviceScopeFactory, busOptionsAccessor, optionsMonitor, loggerFactory) { private readonly EventBusConcurrentDictionary<(Type, bool), InMemorySender> sendersCache = new(); diff --git a/src/Tingle.EventBus/Transports/EventBusTransport.cs b/src/Tingle.EventBus/Transports/EventBusTransport.cs index 64e24d6f..7668c3d9 100644 --- a/src/Tingle.EventBus/Transports/EventBusTransport.cs +++ b/src/Tingle.EventBus/Transports/EventBusTransport.cs @@ -326,10 +326,10 @@ protected async Task SerializeAsync(IServiceScope scope, /// An representing the state of the action. /// protected async Task ConsumeAsync(EventRegistration registration, - EventConsumerRegistration ecr, - EventContext @event, - IServiceScope scope, - CancellationToken cancellationToken) + EventConsumerRegistration ecr, + EventContext @event, + IServiceScope scope, + CancellationToken cancellationToken) where TConsumer : IEventConsumer where TEvent : class { diff --git a/src/Tingle.EventBus/Transports/EventBusTransportConfigureOptions.cs b/src/Tingle.EventBus/Transports/EventBusTransportConfigureOptions.cs index 6aac4a82..2a66d416 100644 --- a/src/Tingle.EventBus/Transports/EventBusTransportConfigureOptions.cs +++ b/src/Tingle.EventBus/Transports/EventBusTransportConfigureOptions.cs @@ -16,9 +16,9 @@ namespace Microsoft.Extensions.DependencyInjection; /// An for bus configuration. public abstract class EventBusTransportConfigureOptions(IEventBusConfigurationProvider configurationProvider, IEnumerable configurators, - IOptions busOptionsAccessor): IConfigureNamedOptions, - IPostConfigureOptions, - IValidateOptions + IOptions busOptionsAccessor) : IConfigureNamedOptions, + IPostConfigureOptions, + IValidateOptions where TOptions : EventBusTransportOptions { // Some hosts do not allow certain characters for ENV vars but we know they all support alphanumeric and underscore