Class: Freddy::ResponderHandler

Inherits:

Object

• Object
• Freddy::ResponderHandler

Defined in:

lib/freddy/responder_handler.rb

Instance Method Summary

• #initialize(consumer, consume_thread_pool) ⇒ ResponderHandler constructor

  A new instance of ResponderHandler.

• #shutdown ⇒ void

  Shutdown responder.

Constructor Details

#initialize(consumer, consume_thread_pool) ⇒ ResponderHandler

Returns a new instance of ResponderHandler.

# File 'lib/freddy/responder_handler.rb', line 3

def initialize(consumer, consume_thread_pool)
  @consumer = consumer
  @consume_thread_pool = consume_thread_pool
end

Instance Method Details

#shutdown ⇒ void

This method returns an undefined value.

Shutdown responder

Stop responding to messages immediately, Waits until all workers are finished and then returns.

Examples:

responder = freddy.respond_to 'Queue' do |msg, handler|
end
responder.shutdown

# File 'lib/freddy/responder_handler.rb', line 19

def shutdown
  @consumer.cancel
  @consume_thread_pool.wait(:done)
end