Sha256: 36865460cdef67655226a79887ff535591756243597557daa9c90dc340e0387f

Contents?: true

Size: 318 Bytes

Versions: 15

Compression:

Stored size: 318 Bytes

Contents

# frozen_string_literal: true

class Freddy
  module Consumers
    class ResponseConsumer
      def initialize(logger)
        @logger = logger
      end

      def consume(_channel, queue, &block)
        @logger.debug "Consuming messages on #{queue.name}"
        queue.subscribe(&block)
      end
    end
  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version Path
freddy-2.8.0 lib/freddy/consumers/response_consumer.rb
freddy-2.7.0 lib/freddy/consumers/response_consumer.rb
freddy-2.6.0 lib/freddy/consumers/response_consumer.rb
freddy-2.5.1 lib/freddy/consumers/response_consumer.rb
freddy-2.5.0 lib/freddy/consumers/response_consumer.rb
freddy-2.5.0.pre.rc.1 lib/freddy/consumers/response_consumer.rb
freddy-2.4.0 lib/freddy/consumers/response_consumer.rb
freddy-2.3.0 lib/freddy/consumers/response_consumer.rb
freddy-2.2.4 lib/freddy/consumers/response_consumer.rb
freddy-2.2.3 lib/freddy/consumers/response_consumer.rb
freddy-2.2.2 lib/freddy/consumers/response_consumer.rb
freddy-2.2.1 lib/freddy/consumers/response_consumer.rb
freddy-2.2.0 lib/freddy/consumers/response_consumer.rb
freddy-2.1.0 lib/freddy/consumers/response_consumer.rb
freddy-2.0.0 lib/freddy/consumers/response_consumer.rb