14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
# File 'lib/rabbit/daemon.rb', line 14
def run
Sneakers.configure(
connection: connection,
env: Rails.env,
exchange_type: :direct,
exchange: Rabbit.config.app_name,
hooks: Rabbit.config.hooks,
supervisor: true,
daemonize: false,
exit_on_detach: true,
**config,
)
unless Sneakers.logger
Sneakers.logger = Logger.new(Rails.root.join("log", "sneakers.log"))
Sneakers.logger.level = Logger::DEBUG
Lamian.extend_logger(Sneakers.logger)
end
Sneakers.server = true
Rabbit.config.validate!
Receiving::Worker.from_queue(Rabbit.config.read_queue)
Sneakers::Runner.new([Receiving::Worker]).run
end
|