diff --git a/Gemfile.lock b/Gemfile.lock index cf788eb..dd4b0f6 100644 --- a/Gemfile.lock +++ b/Gemfile.lock @@ -8,7 +8,7 @@ GIT PATH remote: . specs: - rabbit_messaging (1.6.0) + rabbit_messaging (1.6.1) bunny (~> 2.0) kicks diff --git a/lib/rabbit.rb b/lib/rabbit.rb index b7ccbb1..2e66384 100644 --- a/lib/rabbit.rb +++ b/lib/rabbit.rb @@ -29,10 +29,7 @@ class Config :connection_reset_max_retries, :connection_reset_timeout, :connection_reset_exceptions, - :logger_message_size_limit, - :receive_logger, - :publish_logger, - :malformed_logger + :logger_message_size_limit def initialize( # rubocop:disable Metrics/MethodLength group_id: nil, @@ -76,9 +73,9 @@ def initialize( # rubocop:disable Metrics/MethodLength self.connection_reset_exceptions = connection_reset_exceptions self.logger_message_size_limit = logger_message_size_limit - self.receive_logger = receive_logger || default_receive_logger - self.publish_logger = publish_logger || default_publish_logger - self.malformed_logger = malformed_logger || default_malformed_logger + @receive_logger = receive_logger + @publish_logger = publish_logger + @malformed_logger = malformed_logger end def validate! @@ -103,6 +100,18 @@ def read_queue [app_name, queue_suffix].reject { |x| x.nil? || x.empty? }.join(".") end + def receive_logger + @receive_logger || default_receive_logger + end + + def publish_logger + @publish_logger || default_publish_logger + end + + def malformed_logger + @malformed_logger || default_malformed_logger + end + private def default_receive_logger diff --git a/lib/rabbit/version.rb b/lib/rabbit/version.rb index 89c8181..5436065 100644 --- a/lib/rabbit/version.rb +++ b/lib/rabbit/version.rb @@ -1,5 +1,5 @@ # frozen_string_literal: true module Rabbit - VERSION = "1.6.0" + VERSION = "1.6.1" end