@@ -29,10 +29,7 @@ class Config
2929 :connection_reset_max_retries ,
3030 :connection_reset_timeout ,
3131 :connection_reset_exceptions ,
32- :logger_message_size_limit ,
33- :receive_logger ,
34- :publish_logger ,
35- :malformed_logger
32+ :logger_message_size_limit
3633
3734 def initialize ( # rubocop:disable Metrics/MethodLength
3835 group_id : nil ,
@@ -76,9 +73,9 @@ def initialize( # rubocop:disable Metrics/MethodLength
7673 self . connection_reset_exceptions = connection_reset_exceptions
7774 self . logger_message_size_limit = logger_message_size_limit
7875
79- self . receive_logger = receive_logger || default_receive_logger
80- self . publish_logger = publish_logger || default_publish_logger
81- self . malformed_logger = malformed_logger || default_malformed_logger
76+ @ receive_logger = receive_logger
77+ @ publish_logger = publish_logger
78+ @ malformed_logger = malformed_logger
8279 end
8380
8481 def validate!
@@ -103,6 +100,18 @@ def read_queue
103100 [ app_name , queue_suffix ] . reject { |x | x . nil? || x . empty? } . join ( "." )
104101 end
105102
103+ def receive_logger
104+ @receive_logger || default_receive_logger
105+ end
106+
107+ def publish_logger
108+ @publish_logger || default_publish_logger
109+ end
110+
111+ def malformed_logger
112+ @malformed_logger || default_malformed_logger
113+ end
114+
106115 private
107116
108117 def default_receive_logger
0 commit comments