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