Contents

module NulogyMessageBusConsumer
  module Handlers
    class LogUnprocessedMessages
      def initialize(logger)
        @logger = logger
      end

      def call(message:, **_)
        return if ProcessedMessage.exists?(id: message.id)

        @logger.warn(JSON.dump(
          event: "unprocessed_message",
          kafka_message: message.to_h
        ))
      end
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
nulogy_message_bus_consumer-3.0.0	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
nulogy_message_bus_consumer-2.0.1	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
nulogy_message_bus_consumer-2.0.0	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
nulogy_message_bus_consumer-1.0.0	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
nulogy_message_bus_consumer-0.5.0	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
nulogy_message_bus_consumer-1.0.0.alpha	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
nulogy_message_bus_consumer-0.4.0	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
nulogy_message_bus_consumer-0.3.3	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
nulogy_message_bus_consumer-0.3.2	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb
nulogy_message_bus_consumer-0.3.1	lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb