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)
                 });
             }