diff --git a/lib/outboxer/message.rb b/lib/outboxer/message.rb
index 70691695..7fe78c92 100644
--- a/lib/outboxer/message.rb
+++ b/lib/outboxer/message.rb
@@ -724,5 +724,35 @@ def count_by_status
         ).transform_values(&:to_i)
       end
     end
+
+    def metrics_by_status(time: Time)
+      ActiveRecord::Base.connection_pool.with_connection do
+        ActiveRecord::Base.transaction(isolation: :repeatable_read) do
+          counts = Models::Message::Count.select(
+            "COALESCE(SUM(queued), 0)      AS queued",
+            "COALESCE(SUM(publishing), 0)  AS publishing",
+            "COALESCE(SUM(published), 0)   AS published",
+            "COALESCE(SUM(failed), 0)      AS failed",
+            "COALESCE(SUM(queued + publishing + published + failed), 0) AS total"
+          ).take
+
+          min_times = Models::Message.group(:status).minimum(:updated_at)
+          min_total = min_times.values.compact.min
+
+          now = time.now.utc
+          latencies = min_times.transform_values { |t| t ? (now - t).to_i : 0 }
+          latencies["total"] = min_total ? (now - min_total).to_i : 0
+
+          counts_hash = counts.attributes.symbolize_keys.transform_values(&:to_i)
+
+          [:queued, :publishing, :published, :failed, :total].each_with_object({}) do |status, h|
+            h[status] = {
+              count: counts_hash[status] || 0,
+              latency: latencies[status.to_s] || 0
+            }
+          end
+        end
+      end
+    end
   end
 end
diff --git a/lib/outboxer/models/message.rb b/lib/outboxer/models/message.rb
index 5d4c7401..f68fdf8a 100644
--- a/lib/outboxer/models/message.rb
+++ b/lib/outboxer/models/message.rb
@@ -6,15 +6,15 @@ class Message < ::ActiveRecord::Base
       module Status
         QUEUED = "queued"
         PUBLISHING = "publishing"
-        PUBLISHED = "published"
         FAILED = "failed"
+        PUBLISHED = "published"
       end
 
       STATUSES = [
         Status::QUEUED,
         Status::PUBLISHING,
-        Status::PUBLISHED,
-        Status::FAILED
+        Status::FAILED,
+        Status::PUBLISHED
       ]
 
       # @!attribute [rw] status
@@ -46,8 +46,8 @@ module Status
 
       scope :queued, -> { where(status: Status::QUEUED) }
       scope :publishing, -> { where(status: Status::PUBLISHING) }
-      scope :published, -> { where(status: Status::PUBLISHED) }
       scope :failed, -> { where(status: Status::FAILED) }
+      scope :published, -> { where(status: Status::PUBLISHED) }
 
       # @!method messageable
       #   @return [ActiveRecord::Base] Polymorphic association to an event like model.
diff --git a/lib/outboxer/web.rb b/lib/outboxer/web.rb
index 5c6fb213..1b1f672d 100755
--- a/lib/outboxer/web.rb
+++ b/lib/outboxer/web.rb
@@ -215,12 +215,12 @@ def time_ago_in_words(time)
         per_page: denormalised_query_params[:per_page],
         time_zone: denormalised_query_params[:time_zone])
 
-      message_count_by_status = Message.count_by_status
+      message_metrics_by_status = Message.metrics_by_status
 
       publishers = Publisher.all
 
       erb :home, locals: {
-        message_count_by_status: message_count_by_status,
+        message_metrics_by_status: message_metrics_by_status,
         denormalised_query_params: denormalised_query_params,
         normalised_query_params: normalised_query_params,
         normalised_query_string: normalised_query_string,
@@ -253,12 +253,12 @@ def time_ago_in_words(time)
         per_page: denormalised_query_params[:per_page],
         time_zone: denormalised_query_params[:time_zone])
 
-      message_count_by_status = Message.count_by_status
+      message_metrics_by_status = Message.metrics_by_status
 
       publishers = Publisher.all
 
       erb :home, locals: {
-        message_count_by_status: message_count_by_status,
+        message_metrics_by_status: message_metrics_by_status,
         denormalised_query_params: denormalised_query_params,
         normalised_query_params: normalised_query_params,
         normalised_query_string: normalised_query_string,
@@ -311,7 +311,7 @@ def time_ago_in_words(time)
         per_page: denormalised_query_params[:per_page],
         time_zone: denormalised_query_params[:time_zone])
 
-      message_count_by_status = Message.count_by_status
+      message_metrics_by_status = Message.metrics_by_status
 
       paginated_messages = Message.list(
         status: denormalised_query_params[:status],
@@ -327,7 +327,7 @@ def time_ago_in_words(time)
         denormalised_query_params: denormalised_query_params)
 
       erb :messages, locals: {
-        message_count_by_status: message_count_by_status,
+        message_metrics_by_status: message_metrics_by_status,
         messages: paginated_messages[:messages],
         denormalised_query_params: denormalised_query_params,
         normalised_query_params: normalised_query_params,
@@ -627,7 +627,7 @@ def normalise_query_string(status: Message::LIST_STATUS_DEFAULT,
         per_page: denormalised_query_params[:per_page],
         time_zone: denormalised_query_params[:time_zone])
 
-      message_count_by_status = Message.count_by_status
+      message_metrics_by_status = Message.metrics_by_status
 
       message = Message.find_by_id(id: params[:id])
 
@@ -638,7 +638,7 @@ def normalise_query_string(status: Message::LIST_STATUS_DEFAULT,
         denormalised_query_params: denormalised_query_params,
         normalised_query_params: normalised_query_params,
         normalised_query_string: normalised_query_string,
-        message_count_by_status: message_count_by_status,
+        message_metrics_by_status: message_metrics_by_status,
         message: message,
         messageable: messageable
       }
@@ -654,7 +654,7 @@ def normalise_query_string(status: Message::LIST_STATUS_DEFAULT,
         time_zone: params[:time_zone])
 
       message = Message.find_by_id(id: params[:id])
-      message_count_by_status = Message.count_by_status
+      message_metrics_by_status = Message.metrics_by_status
 
       messageable_class = message[:messageable_type]&.safe_constantize
       messageable = messageable_class&.find_by_id(id: message[:messageable_id])
@@ -662,7 +662,7 @@ def normalise_query_string(status: Message::LIST_STATUS_DEFAULT,
       erb :messageable, locals: {
         message: message,
         messageable: messageable,
-        message_count_by_status: message_count_by_status,
+        message_metrics_by_status: message_metrics_by_status,
         denormalised_query_params: denormalised_query_params
       }
     end
@@ -740,10 +740,10 @@ def normalise_query_string(status: Message::LIST_STATUS_DEFAULT,
 
       publisher = Publisher.find_by_id(id: params[:id])
 
-      message_count_by_status = Message.count_by_status
+      message_metrics_by_status = Message.metrics_by_status
 
       erb :publisher, locals: {
-        message_count_by_status: message_count_by_status,
+        message_metrics_by_status: message_metrics_by_status,
         denormalised_query_params: denormalised_query_params,
         normalised_query_params: normalised_query_params,
         normalised_query_string: normalised_query_string,
diff --git a/lib/outboxer/web/views/home.erb b/lib/outboxer/web/views/home.erb
index 708d803c..8760720e 100644
--- a/lib/outboxer/web/views/home.erb
+++ b/lib/outboxer/web/views/home.erb
@@ -111,21 +111,19 @@
                         <tr>
                             <th scope="col">Status</th>
                             <th scope="col">Count</th>
-                            <th scope="col">Throughput</th>
                             <th scope="col">Latency</th>
                         </tr>
                     </thead>
                     <tbody>
-                        <% ['queued', 'publishing', 'published', 'failed'].each do |status| %>
+                        <% Outboxer::Message::STATUSES.each do |status| %>
                             <tr>
                                 <td class="text-capitalize">
                                     <a class="custom-link" href="<%= outboxer_path("/messages?status=#{status}") %>">
                                         <%= status %>
                                     </a>
                                 </td>
-                                <td><%= Outboxer::Web.pretty_number(number: message_count_by_status[status.to_sym]) %></td>
-                                <td><%= Outboxer::Web.pretty_throughput(per_second: 0) %></td>
-                                <td><%= Outboxer::Web.pretty_duration_from_seconds(seconds: 0) %></td>
+                                <td><%= Outboxer::Web.pretty_number(number: message_metrics_by_status[status.to_sym][:count]) %></td>
+                                <td><%= Outboxer::Web.pretty_duration_from_seconds(seconds: message_metrics_by_status[status.to_sym][:latency]) %></td>
                             </tr>
                         <% end %>
                     </tbody>
diff --git a/lib/outboxer/web/views/layout.erb b/lib/outboxer/web/views/layout.erb
index 83e46732..9ebfb294 100644
--- a/lib/outboxer/web/views/layout.erb
+++ b/lib/outboxer/web/views/layout.erb
@@ -55,7 +55,7 @@
         <div class="container-fluid">
             <a class="navbar-brand" href="<%= outboxer_path('') %>">
                 <i class="bi bi-envelope-open-fill"></i> Outboxer
-                <span class="badge bg-secondary"><%= Outboxer::Web.pretty_number(number: message_count_by_status[:published]) %></span>
+                <span class="badge bg-secondary"><%= Outboxer::Web.pretty_number(number: message_metrics_by_status[:published][:count]) %></span>
             </a>
             <button class="navbar-toggler" type="button" data-bs-toggle="collapse" data-bs-target="#navbarNav" aria-controls="navbarNav" aria-expanded="false" aria-label="Toggle navigation">
                 <span class="navbar-toggler-icon"></span>
@@ -71,7 +71,7 @@
                     <li class="nav-item">
                         <a class="nav-link <%= 'active' if denormalised_query_params[:status] == nil %>"
                            href="<%= outboxer_path("/messages#{normalise_query_string(status: nil, time_zone: denormalised_query_params[:time_zone])}") %>">
-                            All (<%= Outboxer::Web.pretty_number(number: message_count_by_status[:total]) %>)
+                            All (<%= Outboxer::Web.pretty_number(number: message_metrics_by_status[:total][:count]) %>)
                         </a>
                     </li>
 
@@ -79,7 +79,7 @@
                         <li class="nav-item">
                             <a class="nav-link <%= 'active' if denormalised_query_params[:status] == status[:key] %>"
                                href="<%= outboxer_path("/messages#{normalise_query_string(status: status[:key], time_zone: params[:time_zone])}") %>">
-                                <%= status[:name] %> (<%= Outboxer::Web.pretty_number(number: message_count_by_status[status[:key].to_sym]) %>)
+                                <%= status[:name] %> (<%= Outboxer::Web.pretty_number(number: message_metrics_by_status[status[:key].to_sym][:count]) %>)
                             </a>
                         </li>
                     <% end %>
diff --git a/quickstart_e2e_tests.sh b/quickstart_e2e_tests.sh
index f9e5c433..52599530 100755
--- a/quickstart_e2e_tests.sh
+++ b/quickstart_e2e_tests.sh
@@ -76,13 +76,13 @@ attempt = 1
 max_attempts = 10
 delay = 1
 
-published_count = Outboxer::Message.count_by_status[:published]
+published_count = Outboxer::Message.metrics_by_status[:published][:count]
 
 while (attempt <= max_attempts) && published_count.zero?
   warn "Outboxer not published yet (#{attempt}/#{max_attempts})..."
   sleep delay
   attempt += 1
-  published_count = Outboxer::Message.count_by_status[:published]
+  published_count = Outboxer::Message.metrics_by_status[:published][:count]
 end
 
 Process.kill("TERM", publisher_pid)
diff --git a/spec/bin/outboxer_publisher_spec.rb b/spec/bin/outboxer_publisher_spec.rb
index 3e75f652..e822b2a6 100644
--- a/spec/bin/outboxer_publisher_spec.rb
+++ b/spec/bin/outboxer_publisher_spec.rb
@@ -13,13 +13,13 @@
 
   it "publishes message" do
     attempt = 1
-    published_count = Outboxer::Message.count_by_status[:published]
+    published_count = Outboxer::Message.metrics_by_status[:published][:count]
 
     while (attempt <= max_attempts) && published_count.zero?
       warn "Outboxer message not published yet. Retrying (#{attempt}/#{max_attempts})..."
       sleep delay
       attempt += 1
-      published_count = Outboxer::Message.count_by_status[:published]
+      published_count = Outboxer::Message.metrics_by_status[:published][:count]
     end
 
     Process.kill("TERM", publisher_pid)
diff --git a/spec/lib/outboxer/message/delete_spec.rb b/spec/lib/outboxer/message/delete_spec.rb
index ab5fe3be..38d388b0 100644
--- a/spec/lib/outboxer/message/delete_spec.rb
+++ b/spec/lib/outboxer/message/delete_spec.rb
@@ -23,7 +23,7 @@ module Outboxer
         end
 
         it "increments the total failed count metric" do
-          expect(Message.count_by_status[:failed]).to eq(29)
+          expect(Message.metrics_by_status[:failed][:count]).to eq(29)
         end
 
         it "returns the message id" do
@@ -52,7 +52,7 @@ module Outboxer
         end
 
         it "increments the total published count metric" do
-          expect(Message.count_by_status[:published]).to eq(29)
+          expect(Message.metrics_by_status[:published][:count]).to eq(29)
         end
 
         it "returns the message id" do
diff --git a/spec/lib/outboxer/message/count_by_status_spec.rb b/spec/lib/outboxer/message/metrics_by_status_spec.rb
similarity index 71%
rename from spec/lib/outboxer/message/count_by_status_spec.rb
rename to spec/lib/outboxer/message/metrics_by_status_spec.rb
index d9df36e1..ad34c067 100644
--- a/spec/lib/outboxer/message/count_by_status_spec.rb
+++ b/spec/lib/outboxer/message/metrics_by_status_spec.rb
@@ -4,7 +4,7 @@
 
 module Outboxer
   RSpec.describe Message do
-    describe ".count_by_status" do
+    describe ".metrics_by_status" do
       let(:current_utc_time) { Time.utc(2025, 1, 1, 0, 0, 0) }
 
       before { Models::Message::Count.delete_all }
@@ -25,9 +25,14 @@ module Outboxer
         )
       end
 
-      it "returns total counts by status" do
-        expect(Message.count_by_status).to eq(
-          queued: 15, publishing: 26, published: 37, failed: 48, total: 126)
+      it "returns metrics by status" do
+        expect(Message.metrics_by_status).to eq({
+          queued: { count: 15, latency: 0 },
+          publishing: { count: 26, latency: 0 },
+          published: { count: 37, latency: 0 },
+          failed: { count: 48, latency: 0 },
+          total: { count: 126, latency: 0 }
+        })
       end
     end
   end