diff --git a/lib/outboxer/message.rb b/lib/outboxer/message.rb
index 601a8f83..e4e56655 100644
--- a/lib/outboxer/message.rb
+++ b/lib/outboxer/message.rb
@@ -339,7 +339,9 @@ def published(id:, lock_version:, time: ::Time)
             .where(status: Status::PUBLISHED, partition: partition)
             .update_all(["value = value + ?, updated_at = ?", 1, current_utc_time])
 
-          {}
+          {
+            id: message.id
+          }
         end
       end
     end
@@ -398,6 +400,7 @@ def publishing_failed(id:, lock_version:, error: nil, time: ::Time)
             .update_all(["value = value + ?, updated_at = ?", 1, current_utc_time])
 
           {
+            id: message.id,
             lock_version: message.lock_version
           }
         end
@@ -562,7 +565,10 @@ def requeue(id:, lock_version:, publisher_id: nil, publisher_name: nil,
             .where(status: message.status, partition: partition)
             .update_all(["value = value + ?, updated_at = ?", 1, current_utc_time])
 
-          { id: id }
+          {
+            id: id,
+            lock_version: lock_version
+          }
         end
       end
     end