Sha256: 5a87f9b0462aa563c228eba5b348ff9e0cdd38dcd5f998d36c7b3e4dbb1628a0
Contents?: true
Size: 560 Bytes
Versions: 37
Compression:
Stored size: 560 Bytes
Contents
class Freddy
class ResponderHandler
def initialize(consumer, consume_thread_pool)
@consumer = consumer
@consume_thread_pool = consume_thread_pool
end
# Shutdown responder
#
# Stop responding to messages immediately, Waits until all workers are
# finished and then returns.
#
# @return [void]
#
# @example
# responder = freddy.respond_to 'Queue' do |msg, handler|
# end
# responder.shutdown
def shutdown
@consumer.cancel
@consume_thread_pool.wait(:done)
end
end
end
Version data entries
37 entries across 37 versions & 2 rubygems