lib/cyclone_lariat/middleware.rb in cyclone_lariat-1.0.0.rc5 vs lib/cyclone_lariat/middleware.rb in cyclone_lariat-1.0.0.rc6

- old
+ new

@@ -1,17 +1,17 @@ # frozen_string_literal: true -require 'cyclone_lariat/repo/messages' +require 'cyclone_lariat/repo/inbox_messages' require 'cyclone_lariat/core' require 'luna_park/errors' require 'cyclone_lariat/messages/builder' require 'json' module CycloneLariat class Middleware attr_reader :config - def initialize(errors_notifier: nil, message_notifier: nil, repo: Repo::Messages, **options) + def initialize(errors_notifier: nil, message_notifier: nil, repo: Repo::InboxMessages, **options) @config = CycloneLariat::Options.wrap(options).merge!(CycloneLariat.config) @events_repo = repo.new(**@config.to_h) @message_notifier = message_notifier @errors_notifier = errors_notifier end