diff --git a/src/Http/Wolverine.AdminApi/WolverineAdminApiExtensions.cs b/src/Http/Wolverine.AdminApi/WolverineAdminApiExtensions.cs index 979d14e7d..287d78806 100644 --- a/src/Http/Wolverine.AdminApi/WolverineAdminApiExtensions.cs +++ b/src/Http/Wolverine.AdminApi/WolverineAdminApiExtensions.cs @@ -67,9 +67,10 @@ private static async Task buildStorageTable(IWolverineRuntime runtime, row.Header("Database Name"); } row.Header("Incoming"); + row.Header("Outgoing"); row.Header("Scheduled"); + row.Header("Dead Letter"); row.Header("Handled"); - row.Header("Outgoing"); }); if (hasMultiples) @@ -80,9 +81,10 @@ private static async Task buildStorageTable(IWolverineRuntime runtime, { row.Cell(pair.Key); row.Cell(pair.Value.Incoming.ToString()); + row.Cell(pair.Value.Outgoing.ToString()); row.Cell(pair.Value.Scheduled.ToString()); + row.Cell(pair.Value.DeadLetter.ToString()); row.Cell(pair.Value.Handled.ToString()); - row.Cell(pair.Value.Outgoing.ToString()); }); } } @@ -91,9 +93,10 @@ private static async Task buildStorageTable(IWolverineRuntime runtime, table.AddBodyRow(row => { row.Cell(counts.Incoming.ToString()); + row.Cell(counts.Outgoing.ToString()); row.Cell(counts.Scheduled.ToString()); + row.Cell(counts.DeadLetter.ToString()); row.Cell(counts.Handled.ToString()); - row.Cell(counts.Outgoing.ToString()); }); } @@ -139,4 +142,4 @@ private static async Task buildNodesTable(IWolverineRuntime runtime, C return table; } -} \ No newline at end of file +} diff --git a/src/Wolverine/Persistence/Durability/MessageStoreResource.cs b/src/Wolverine/Persistence/Durability/MessageStoreResource.cs index a79665c6c..556f58da6 100644 --- a/src/Wolverine/Persistence/Durability/MessageStoreResource.cs +++ b/src/Wolverine/Persistence/Durability/MessageStoreResource.cs @@ -44,12 +44,14 @@ public async Task DetermineStatus(CancellationToken token) var table = new Table(); table.AddColumns("Envelope Category", "Number"); table.AddRow("Incoming", counts.Incoming.ToString()); - table.AddRow("Scheduled", counts.Scheduled.ToString()); table.AddRow("Outgoing", counts.Outgoing.ToString()); + table.AddRow("Scheduled", counts.Scheduled.ToString()); + table.AddRow("Dead Letter", counts.DeadLetter.ToString()); + table.AddRow("Handled", counts.Handled.ToString()); return table; } public string Type => "Wolverine"; public string Name => "Envelope Storage"; -} \ No newline at end of file +} diff --git a/src/Wolverine/Persistence/StorageCommand.cs b/src/Wolverine/Persistence/StorageCommand.cs index 8c98ab9f7..51644a12b 100644 --- a/src/Wolverine/Persistence/StorageCommand.cs +++ b/src/Wolverine/Persistence/StorageCommand.cs @@ -55,6 +55,7 @@ public override async Task Execute(StorageInput input) table.AddRow("Outgoing", counts.Outgoing.ToString()); table.AddRow("Scheduled", counts.Scheduled.ToString()); table.AddRow("Dead Letter", counts.DeadLetter.ToString()); + table.AddRow("Handled", counts.Handled.ToString()); AnsiConsole.Write(table); @@ -90,4 +91,4 @@ public override async Task Execute(StorageInput input) return true; } -} \ No newline at end of file +}