Sha256: 78a7394435187e3f34620f1174d509b0c760bc13a22a07462a12a35c3753ae76
Contents?: true
Size: 715 Bytes
Versions: 30
Compression:
Stored size: 715 Bytes
Contents
require 'dry/container'
module Messaging
module Adapters
extend Dry::Container::Mixin
class Consumer
extend Dry::Container::Mixin
def self.default
resolve(Config.consumer.adapter)
end
end
class Dispatcher
extend Dry::Container::Mixin
def self.default
resolve(Config.dispatcher.adapter)
end
end
class Store
extend Dry::Container::Mixin
def self.default
resolve(Config.message_store.adapter)
end
end
end
end
Messaging::Adapters::Dispatcher.register(:null_adapter, memoize: true) { proc {} }
require 'messaging/adapters/kafka'
require 'messaging/adapters/postgres'
require 'messaging/adapters/test'
Version data entries
30 entries across 30 versions & 1 rubygems