Sha256: 79a6af63d378e7b4497b7d4bd872444a6b00724d7dc337cd3a464562792417e1

Contents?: true

Size: 519 Bytes

Versions: 3

Compression:

Stored size: 519 Bytes

Contents

class Freddy
  module Consumers
    def self.log_receive_event(logger, queue_name, delivery)
      if defined?(Logasm) && logger.is_a?(Logasm)
        logger.debug "Received message", queue: queue_name, payload: delivery.payload, correlation_id: delivery.correlation_id
      else
        logger.debug "Received message on #{queue_name} with payload #{delivery.payload} with correlation_id #{delivery.correlation_id}"
      end
    end
  end
end

Dir[File.dirname(__FILE__) + '/consumers/*.rb'].each(&method(:require))

Version data entries

3 entries across 3 versions & 2 rubygems

Version Path
freddy-jruby-0.5.6 lib/freddy/consumers.rb
freddy-0.5.6 lib/freddy/consumers.rb
freddy-0.5.5 lib/freddy/consumers.rb