mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
20 lines
290 B
Ruby
20 lines
290 B
Ruby
require 'celluloid'
|
|
|
|
module Sidekiq
|
|
|
|
##
|
|
# Represents a connection to our MQ server.
|
|
#
|
|
class Server
|
|
include Celluloid
|
|
|
|
def initialize(location, options={})
|
|
@workers = []
|
|
|
|
options[:worker_count].times do
|
|
@workers << Worker.new
|
|
end
|
|
end
|
|
|
|
end
|
|
end
|