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

require 'messaging/adapters/kafka'
require 'messaging/adapters/postgres'
require 'messaging/adapters/test'

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
messaging-3.5.1	lib/messaging/adapters.rb
messaging-3.4.3	lib/messaging/adapters.rb
messaging-3.4.2	lib/messaging/adapters.rb
messaging-3.4.1	lib/messaging/adapters.rb