diff --git a/src/Ports/NetSampleArch.Ports.Consumers/Consumers/Commands/PersonCreatedEventHandler.cs b/src/Ports/NetSampleArch.Ports.Consumers/Consumers/Commands/PersonCreatedEventHandler.cs new file mode 100644 index 0000000..38de39a --- /dev/null +++ b/src/Ports/NetSampleArch.Ports.Consumers/Consumers/Commands/PersonCreatedEventHandler.cs @@ -0,0 +1,25 @@ +using System.Threading; +using System.Threading.Tasks; +using Confluent.Kafka; +using NetSampleArch.Infra.CrossCutting.Bus.Interfaces; +using NetSampleArch.Infra.CrossCutting.Configuration; +using NetSampleArch.Ports.Consumers.Interfaces.Commands; +using Serilog; + +namespace NetSampleArch.Ports.Consumers.Consumers.Commands +{ + public class PersonCreatedEventHandler + : BaseKafkaConsumer, IPersonCreatedEventHandler + { + public PersonCreatedEventHandler(ILogger logger, IBus bus, Configuration configuration) + : base(logger, bus, configuration) + { + + } + + public override Task MessageReceivedAsync(ConsumeResult receivedMessage, CancellationToken cancellationToken) + { + throw new System.NotImplementedException(); + } + } +} \ No newline at end of file diff --git a/src/Ports/NetSampleArch.Ports.Consumers/Interfaces/Commands/IPersonCreatedEventHandler.cs b/src/Ports/NetSampleArch.Ports.Consumers/Interfaces/Commands/IPersonCreatedEventHandler.cs new file mode 100644 index 0000000..3d9da25 --- /dev/null +++ b/src/Ports/NetSampleArch.Ports.Consumers/Interfaces/Commands/IPersonCreatedEventHandler.cs @@ -0,0 +1,7 @@ +namespace NetSampleArch.Ports.Consumers.Interfaces.Commands +{ + public interface IPersonCreatedEventHandler : IKafkaConsumer + { + + } +} \ No newline at end of file