being able to customize aws sns topic name

src/JKang.EventBus.AmazonSns/AmazonSnsEventBus.cs

@@ -2,6 +2,8 @@
 using Amazon.SimpleNotificationService;
 using Amazon.SimpleNotificationService.Model;
 using Microsoft.Extensions.Options;
+using System;
+using System.Linq;
 using System.Threading.Tasks;
 
 namespace JKang.EventBus.AmazonSns
@@ -23,7 +25,15 @@ public async Task PublishEventAsync<TEvent>(TEvent @event)
         {
             var endpoint = RegionEndpoint.GetBySystemName(_options.Value.Region);
             var client = new AmazonSimpleNotificationServiceClient(endpoint);
-            string topicName = typeof(TEvent).FullName.ToLower().Replace('.', '-');
+
+            Type eventType = typeof(TEvent);
+            AmazonSnsTopicAttribute attr = eventType
+                .GetCustomAttributes(typeof(AmazonSnsTopicAttribute), inherit: false)
+                .OfType<AmazonSnsTopicAttribute>()
+                .FirstOrDefault();
+            string topicName = attr == null
+                ? eventType.FullName.ToLower().Replace('.', '-')
+                : attr.Name;
             var createTopicRequest = new CreateTopicRequest(topicName);
             CreateTopicResponse createTopicResponse = await client.CreateTopicAsync(createTopicRequest);
             string topicArn = createTopicResponse.TopicArn;

src/JKang.EventBus.AmazonSns/AmazonSnsTopicAttribute.cs

@@ -0,0 +1,15 @@
+using System;
+
+namespace JKang.EventBus.AmazonSns
+{
+    [AttributeUsage(AttributeTargets.Class, AllowMultiple = false, Inherited = false)]
+    public class AmazonSnsTopicAttribute: Attribute
+    {
+        public AmazonSnsTopicAttribute(string name)
+        {
+            Name = name;
+        }
+
+        public string Name { get; }
+    }
+}

src/JKang.EventBus.Core/DependencyInjection/EventPublisherProvider.cs

@@ -21,10 +21,7 @@ public EventPublisherProvider(
 
         public IEnumerable<IEventPublisher> GetEventPublishers()
         {
-            using (IServiceScope scope = _serviceProvider.CreateScope())
-            {
-                return _eventPublishers.Types.Select(t => (IEventPublisher)scope.ServiceProvider.GetService(t));
-            }
+            return _eventPublishers.Types.Select(t => (IEventPublisher)_serviceProvider.GetService(t));
         }
     }
 }

src/JKang.EventBus.Core/EventBusBuilderExtensions.cs

@@ -1,5 +1,4 @@
-using JKang.EventBus;
-using JKang.EventBus.InMemory;
+using JKang.EventBus.InMemory;
 using JKang.EventBus.Serialization;
 using System;
 
@@ -14,11 +13,7 @@ public static IEventBusBuilder AddInMemoryEventBus(this IEventBusBuilder builder
                 throw new ArgumentNullException(nameof(builder));
             }
 
-            builder.Services
-                .AddSingleton<IEventPublisher, InMemoryEventBus>()
-                ;
-
-            return builder;
+            return builder.AddEventPublisher<InMemoryEventBus>();
         }
 
         public static IEventBusBuilder UseJsonSerializer(this IEventBusBuilder builder)

src/Samples.EventBus.AspNetCore/Events/MessageSent.cs

@@ -1,5 +1,8 @@
-namespace JKang.EventBus.Samples.InMemory.AspNetCore.Events
+using JKang.EventBus.AmazonSns;
+
+namespace JKang.EventBus.Samples.InMemory.AspNetCore.Events
 {
+    [AmazonSnsTopic("my-message")]
     public class MessageSent
     {
         public MessageSent(string message) => Message = message;