Class: Freddy::Consumers::RespondToConsumer
- Inherits:
-
Object
- Object
- Freddy::Consumers::RespondToConsumer
- Defined in:
- lib/freddy/consumers/respond_to_consumer.rb
Class Method Summary collapse
Instance Method Summary collapse
- #consume(&block) ⇒ Object
-
#initialize(thread_pool:, destination:, channel:, handler_adapter_factory:) ⇒ RespondToConsumer
constructor
A new instance of RespondToConsumer.
Constructor Details
#initialize(thread_pool:, destination:, channel:, handler_adapter_factory:) ⇒ RespondToConsumer
Returns a new instance of RespondToConsumer.
8 9 10 11 12 13 |
# File 'lib/freddy/consumers/respond_to_consumer.rb', line 8 def initialize(thread_pool:, destination:, channel:, handler_adapter_factory:) @consume_thread_pool = thread_pool @destination = destination @channel = channel @handler_adapter_factory = handler_adapter_factory end |
Class Method Details
.consume(*attrs, &block) ⇒ Object
4 5 6 |
# File 'lib/freddy/consumers/respond_to_consumer.rb', line 4 def self.consume(*attrs, &block) new(*attrs).consume(&block) end |
Instance Method Details
#consume(&block) ⇒ Object
15 16 17 18 19 20 21 22 23 24 |
# File 'lib/freddy/consumers/respond_to_consumer.rb', line 15 def consume(&block) consumer = consume_from_destination do |delivery| adapter = @handler_adapter_factory.for(delivery) msg_handler = MessageHandler.new(adapter, delivery) block.call(delivery.payload, msg_handler) end ResponderHandler.new(consumer, @consume_thread_pool) end |