Refactor > optimised publishing

db/migrate/create_outboxer_message_counters.rb

@@ -0,0 +1,30 @@
+class CreateOutboxerMessageCounters < ActiveRecord::Migration[6.1]
+  def up
+    create_table :outboxer_message_counters do |t|
+      t.string  :hostname, limit: 255, null: false
+      t.integer :process_id, null: false
+      t.integer :thread_id, null: false
+
+      t.integer :queued_count, null: false
+      t.datetime :queued_count_last_updated_at, precision: 6
+
+      t.integer :publishing_count, null: false
+      t.datetime :publishing_count_last_updated_at, precision: 6
+
+      t.integer :published_count, null: false
+      t.datetime :published_count_last_updated_at, precision: 6
+
+      t.integer :failed_count, null: false
+      t.datetime :failed_count_last_updated_at, precision: 6
+
+      t.timestamps null: false
+    end
+
+    add_index :outboxer_message_counters, [:hostname, :process_id, :thread_id],
+      unique: true, name: "idx_outboxer_message_counters_identity"
+  end
+
+  def down
+    drop_table :outboxer_message_counters if table_exists?(:outboxer_message_counters)
+  end
+end

lib/outboxer.rb

@@ -8,7 +8,7 @@
 require_relative "outboxer/models/frame"
 require_relative "outboxer/models/exception"
 require_relative "outboxer/models/message"
-require_relative "outboxer/models/message/count"
+require_relative "outboxer/models/message/counter"
 
 require_relative "outboxer/models/publisher"
 require_relative "outboxer/models/signal"

lib/outboxer/database.rb

@@ -85,7 +85,7 @@ def truncate(logger: nil)
             TRUNCATE TABLE
               outboxer_frames,
               outboxer_exceptions,
-              outboxer_message_counts,
+              outboxer_message_counters,
               outboxer_messages,
               outboxer_signals,
               outboxer_publishers
@@ -98,7 +98,7 @@ def truncate(logger: nil)
             connection.execute("SET FOREIGN_KEY_CHECKS = 0;")
             connection.execute("TRUNCATE TABLE outboxer_frames;")
             connection.execute("TRUNCATE TABLE outboxer_exceptions;")
-            connection.execute("TRUNCATE TABLE outboxer_message_counts;")
+            connection.execute("TRUNCATE TABLE outboxer_message_counters;")
             connection.execute("TRUNCATE TABLE outboxer_messages;")
             connection.execute("TRUNCATE TABLE outboxer_signals;")
             connection.execute("TRUNCATE TABLE outboxer_publishers;")