Sha256: 3a83cf8570a48053ed59f26f38f22dd4590617772b482316c015c9c62f574abf
Contents?: true
Size: 732 Bytes
Versions: 11
Compression:
Stored size: 732 Bytes
Contents
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
Version data entries
11 entries across 11 versions & 1 rubygems