lib/alephant/publisher/queue/sqs_helper/archiver.rb in alephant-publisher-queue-2.1.4 vs lib/alephant/publisher/queue/sqs_helper/archiver.rb in alephant-publisher-queue-2.2.0

@@ -44,10 +44,10 @@
             store_item(message).tap do
               logger.info(
                 "event"       => "MessageStored",
                 "messageBody" => msg_body,
                 "method"      => "#{self.class}#store"
-              ) if log_validator.(msg_body)
+              ) if log_validator.call(msg_body)
             end
           end
 
           def store_item(message)
             cache.put(