Commit 559380c1 by dingsongjie

fix bug

parent 88a47a80
......@@ -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);
......
......@@ -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)
});
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment