From 559380c1561e25616e8cacdadfed1acf859e4f69 Mon Sep 17 00:00:00 2001
From: dingsongjie <dingsongjie@DESKTOP-0AS088R>
Date: Thu, 27 Feb 2020 16:06:49 +0800
Subject: [PATCH] fix bug

---
 src/Pole.EventBus.Rabbitmq/Consumer/ConsumerRunner.cs      | 1 -
 src/Pole.EventStorage.PostgreSql/PostgreSqlEventStorage.cs | 3 ++-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Pole.EventBus.Rabbitmq/Consumer/ConsumerRunner.cs b/src/Pole.EventBus.Rabbitmq/Consumer/ConsumerRunner.cs
index 1b2083a..dc55077 100644
--- a/src/Pole.EventBus.Rabbitmq/Consumer/ConsumerRunner.cs
+++ b/src/Pole.EventBus.Rabbitmq/Consumer/ConsumerRunner.cs
@@ -62,7 +62,6 @@ namespace Pole.EventBus.RabbitMQ
             BasicConsumer = new EventingBasicConsumer(Model.Model);
             BasicConsumer.Received += async (ch, ea) =>
             {
-
                 await mpscChannel.WriteAsync(ea);
             };
             BasicConsumer.ConsumerTag = Model.Model.BasicConsume(Queue.Queue, Consumer.Config.AutoAck, BasicConsumer);
diff --git a/src/Pole.EventStorage.PostgreSql/PostgreSqlEventStorage.cs b/src/Pole.EventStorage.PostgreSql/PostgreSqlEventStorage.cs
index ae4d464..ed76495 100644
--- a/src/Pole.EventStorage.PostgreSql/PostgreSqlEventStorage.cs
+++ b/src/Pole.EventStorage.PostgreSql/PostgreSqlEventStorage.cs
@@ -92,7 +92,8 @@ $"UPDATE {tableName} SET \"Retries\"=@Retries,\"ExpiresAt\"=@ExpiresAt,\"StatusN
                     Name = reader.GetString(2),
                     Content = reader.GetString(3),
                     Retries = reader.GetInt32(4),
-                    Added = reader.GetDateTime(5)
+                    Added = reader.GetDateTime(5),
+                    StatusName = reader.GetString(7)
                 });
             }
 
--
libgit2 0.25.0