Merge pull request #8 from arikarim/dev

Updates rabbit_carrots to version 1.0.4 and adds 'English' module req…
This commit is contained in:
Brusk Awat 2025-05-25 15:15:59 +03:00 committed by GitHub
commit 35586d81b4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 7 additions and 5 deletions

View File

@ -1,7 +1,7 @@
PATH PATH
remote: . remote: .
specs: specs:
rabbit_carrots (1.0.3) rabbit_carrots (1.0.4)
bunny (>= 2.22) bunny (>= 2.22)
connection_pool (~> 2.4) connection_pool (~> 2.4)

View File

@ -1,5 +1,4 @@
# rabbit_carrots.rb # rabbit_carrots.rb
require 'puma/plugin' require 'puma/plugin'
require 'rabbit_carrots' require 'rabbit_carrots'
@ -8,7 +7,7 @@ Puma::Plugin.create do
def start(launcher) def start(launcher)
@log_writer = launcher.log_writer @log_writer = launcher.log_writer
@puma_pid = $PROCESS_ID @puma_pid = $$
@core_service = RabbitCarrots::Core.new(logger: log_writer) @core_service = RabbitCarrots::Core.new(logger: log_writer)
@ -58,7 +57,7 @@ Puma::Plugin.create do
loop do loop do
if send(process_dead) if send(process_dead)
log message log message
Process.kill('TERM', $PROCESS_ID) Process.kill('TERM', $$)
break break
end end
sleep 2 sleep 2

View File

@ -125,12 +125,15 @@ module RabbitCarrots
def adapter.info(msg) def adapter.info(msg)
@logger.write("[INFO] #{msg}\n") @logger.write("[INFO] #{msg}\n")
end end
def adapter.error(msg) def adapter.error(msg)
@logger.write("[ERROR] #{msg}\n") @logger.write("[ERROR] #{msg}\n")
end end
def adapter.warn(msg) def adapter.warn(msg)
@logger.write("[WARN] #{msg}\n") @logger.write("[WARN] #{msg}\n")
end end
adapter.instance_variable_set(:@logger, logger) adapter.instance_variable_set(:@logger, logger)
adapter adapter
end end

View File

@ -1,5 +1,5 @@
# frozen_string_literal: true # frozen_string_literal: true
module RabbitCarrots module RabbitCarrots
VERSION = '1.0.3' VERSION = '1.0.4'
end end