require 'active_record'
require_relative 'postgres/serialized_message'
require_relative 'postgres/advisory_transaction_lock'

require_relative 'postgres/store'
module Messaging
  module Adapters
    # Adapter for using Postgres and Active Record as a message store.
    # @see Messaging::Adapters::Postgres::Store Store - for more information on how to use the message store
    # capabilities provided by this adapter.
    class Postgres
      def self.register!
        return if Adapters.key? :postgres

        Adapters.register(:postgres, memoize: true) { Postgres.new }
        Adapters::Store.register(:postgres, memoize: true) { Store.new }
      end
      private_class_method :register!

      register!
    end
  end
end