From cbc7c5e3463c2daf6419b2363015d9c296a4e538 Mon Sep 17 00:00:00 2001
From: italosantana <flaubert165@gmail.com>
Date: Tue, 6 Apr 2021 14:27:37 -0300
Subject: [PATCH] person entry consumer

---
 .../Commands/PersonCreatedEventHandler.cs     | 25 +++++++++++++++++++
 .../Commands/IPersonCreatedEventHandler.cs    |  7 ++++++
 2 files changed, 32 insertions(+)
 create mode 100644 src/Ports/NetSampleArch.Ports.Consumers/Consumers/Commands/PersonCreatedEventHandler.cs
 create mode 100644 src/Ports/NetSampleArch.Ports.Consumers/Interfaces/Commands/IPersonCreatedEventHandler.cs

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<PersonCreatedEventHandler>, IPersonCreatedEventHandler
+    {
+        public PersonCreatedEventHandler(ILogger logger, IBus  bus, Configuration configuration)
+            : base(logger, bus, configuration)
+        {
+            
+        }
+
+        public override Task MessageReceivedAsync(ConsumeResult<Ignore, string> 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