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 |