mirror of
https://github.com/ditkrg/rabbit_carrots.git
synced 2026-01-22 22:06:40 +00:00
Merge pull request #1 from arikarim/Rails_logger
Add Logger production path
This commit is contained in:
commit
6c53348d0a
10
Gemfile
10
Gemfile
@ -1,12 +1,14 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
source "https://rubygems.org"
|
||||
source 'https://rubygems.org'
|
||||
|
||||
# Specify your gem's dependencies in rabbit_carrots.gemspec
|
||||
gemspec
|
||||
|
||||
gem "rake", "~> 13.0"
|
||||
gem 'rake', '~> 13.0'
|
||||
|
||||
gem "rspec", "~> 3.0"
|
||||
gem 'rspec', '~> 3.0'
|
||||
|
||||
gem "rubocop", "~> 1.21"
|
||||
gem 'rubocop', '~> 1.21'
|
||||
|
||||
gem 'rubocop-rails', '~> 2.17'
|
||||
|
||||
21
Gemfile.lock
21
Gemfile.lock
@ -1,24 +1,34 @@
|
||||
PATH
|
||||
remote: .
|
||||
specs:
|
||||
rabbit_carrots (0.1.14)
|
||||
rabbit_carrots (0.1.15)
|
||||
bunny (>= 2.19.0)
|
||||
connection_pool (~> 2.3.0)
|
||||
|
||||
GEM
|
||||
remote: https://rubygems.org/
|
||||
specs:
|
||||
activesupport (7.0.4)
|
||||
concurrent-ruby (~> 1.0, >= 1.0.2)
|
||||
i18n (>= 1.6, < 2)
|
||||
minitest (>= 5.1)
|
||||
tzinfo (~> 2.0)
|
||||
amq-protocol (2.3.2)
|
||||
ast (2.4.2)
|
||||
bunny (2.19.0)
|
||||
amq-protocol (~> 2.3, >= 2.3.1)
|
||||
sorted_set (~> 1, >= 1.0.2)
|
||||
concurrent-ruby (1.1.10)
|
||||
connection_pool (2.3.0)
|
||||
diff-lcs (1.5.0)
|
||||
i18n (1.12.0)
|
||||
concurrent-ruby (~> 1.0)
|
||||
json (2.6.2)
|
||||
minitest (5.16.3)
|
||||
parallel (1.22.1)
|
||||
parser (3.1.2.1)
|
||||
ast (~> 2.4.1)
|
||||
rack (3.0.1)
|
||||
rainbow (3.1.1)
|
||||
rake (13.0.6)
|
||||
rbtree (0.4.5)
|
||||
@ -49,11 +59,17 @@ GEM
|
||||
unicode-display_width (>= 1.4.0, < 3.0)
|
||||
rubocop-ast (1.23.0)
|
||||
parser (>= 3.1.1.0)
|
||||
rubocop-rails (2.17.3)
|
||||
activesupport (>= 4.2.0)
|
||||
rack (>= 1.1)
|
||||
rubocop (>= 1.33.0, < 2.0)
|
||||
ruby-progressbar (1.11.0)
|
||||
set (1.0.3)
|
||||
sorted_set (1.0.3)
|
||||
rbtree
|
||||
set (~> 1.0)
|
||||
tzinfo (2.0.5)
|
||||
concurrent-ruby (~> 1.0)
|
||||
unicode-display_width (2.3.0)
|
||||
|
||||
PLATFORMS
|
||||
@ -64,6 +80,7 @@ DEPENDENCIES
|
||||
rake (~> 13.0)
|
||||
rspec (~> 3.0)
|
||||
rubocop (~> 1.21)
|
||||
rubocop-rails (~> 2.17)
|
||||
|
||||
BUNDLED WITH
|
||||
2.3.23
|
||||
2.3.26
|
||||
|
||||
6
Rakefile
6
Rakefile
@ -1,11 +1,11 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require "bundler/gem_tasks"
|
||||
require "rspec/core/rake_task"
|
||||
require 'bundler/gem_tasks'
|
||||
require 'rspec/core/rake_task'
|
||||
|
||||
RSpec::Core::RakeTask.new(:spec)
|
||||
|
||||
require "rubocop/rake_task"
|
||||
require 'rubocop/rake_task'
|
||||
|
||||
RuboCop::RakeTask.new
|
||||
|
||||
|
||||
@ -1,24 +1,23 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require_relative "rabbit_carrots/version"
|
||||
require_relative 'rabbit_carrots/version'
|
||||
require 'rabbit_carrots/connection'
|
||||
require 'rabbit_carrots/configuration'
|
||||
require 'rabbit_carrots/railtie' if defined?(Rails)
|
||||
|
||||
|
||||
module RabbitCarrots
|
||||
class Error < StandardError; end
|
||||
|
||||
module EventHandlers
|
||||
module Errors
|
||||
class IrrelevantMessage < StandardError
|
||||
end
|
||||
|
||||
|
||||
class NackMessage < StandardError
|
||||
end
|
||||
|
||||
|
||||
class NackAndRequeueMessage < StandardError
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
@ -4,7 +4,7 @@ module RabbitCarrots
|
||||
class Connection
|
||||
include ::Singleton
|
||||
attr_reader :connection
|
||||
|
||||
|
||||
def initialize
|
||||
@connection = Bunny.new(
|
||||
host: RabbitCarrots.configuration.rabbitmq_host,
|
||||
@ -16,11 +16,11 @@ module RabbitCarrots
|
||||
|
||||
@connection.start
|
||||
end
|
||||
|
||||
|
||||
def channel
|
||||
@channel ||= ConnectionPool.new do
|
||||
connection.create_channel
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@ -10,4 +10,4 @@ module RabbitCarrots
|
||||
Dir.glob("#{path}/tasks/**/*.rake").each { |f| load f }
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@ -10,7 +10,7 @@ namespace :rabbit_carrots do
|
||||
{ **mapping, handler: mapping[:handler].constantize }
|
||||
end
|
||||
|
||||
Rails.logger = Logger.new($stdout)
|
||||
Rails.logger = Logger.new(Rails.env.production? ? '/proc/self/fd/1' : $stdout)
|
||||
|
||||
# Run RMQ Subscriber for each channel
|
||||
channels.each do |channel|
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module RabbitCarrots
|
||||
VERSION = "0.1.14"
|
||||
VERSION = '0.1.15'
|
||||
end
|
||||
|
||||
@ -1,24 +1,24 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require_relative "lib/rabbit_carrots/version"
|
||||
require_relative 'lib/rabbit_carrots/version'
|
||||
|
||||
Gem::Specification.new do |spec|
|
||||
spec.name = "rabbit_carrots"
|
||||
spec.name = 'rabbit_carrots'
|
||||
spec.version = RabbitCarrots::VERSION
|
||||
spec.authors = ["Brusk Awat"]
|
||||
spec.email = ["broosk.edogawa@gmail.com"]
|
||||
spec.authors = ['Brusk Awat']
|
||||
spec.email = ['broosk.edogawa@gmail.com']
|
||||
|
||||
spec.summary = "A simple RabbitMQ consumer task"
|
||||
spec.description = "A background task based on rake to consume RabbitMQ messages"
|
||||
spec.homepage = "https://github.com/ditkrg"
|
||||
spec.license = "MIT"
|
||||
spec.required_ruby_version = ">= 3.1.0"
|
||||
spec.summary = 'A simple RabbitMQ consumer task'
|
||||
spec.description = 'A background task based on rake to consume RabbitMQ messages'
|
||||
spec.homepage = 'https://github.com/ditkrg'
|
||||
spec.license = 'MIT'
|
||||
spec.required_ruby_version = '>= 3.1.0'
|
||||
|
||||
spec.metadata["allowed_push_host"] = "https://rubygems.org"
|
||||
spec.metadata['allowed_push_host'] = 'https://rubygems.org'
|
||||
|
||||
spec.metadata["homepage_uri"] = spec.homepage
|
||||
spec.metadata["source_code_uri"] = "https://github.com/ditkrg/rabbit_carrots"
|
||||
spec.metadata["changelog_uri"] = "https://github.com/ditkrg/rabbit_carrots"
|
||||
spec.metadata['homepage_uri'] = spec.homepage
|
||||
spec.metadata['source_code_uri'] = 'https://github.com/ditkrg/rabbit_carrots'
|
||||
spec.metadata['changelog_uri'] = 'https://github.com/ditkrg/rabbit_carrots'
|
||||
|
||||
# Specify which files should be added to the gem when it is released.
|
||||
# The `git ls-files -z` loads the files in the RubyGem that have been added into git.
|
||||
@ -27,14 +27,15 @@ Gem::Specification.new do |spec|
|
||||
(f == __FILE__) || f.match(%r{\A(?:(?:bin|test|spec|features)/|\.(?:git|travis|circleci)|appveyor)})
|
||||
end
|
||||
end
|
||||
spec.bindir = "exe"
|
||||
spec.bindir = 'exe'
|
||||
spec.executables = spec.files.grep(%r{\Aexe/}) { |f| File.basename(f) }
|
||||
spec.require_paths = ["lib"]
|
||||
spec.require_paths = ['lib']
|
||||
|
||||
# Uncomment to register a new dependency of your gem
|
||||
spec.add_dependency "bunny", ">= 2.19.0"
|
||||
spec.add_dependency "connection_pool", "~> 2.3.0"
|
||||
spec.add_dependency 'bunny', '>= 2.19.0'
|
||||
spec.add_dependency 'connection_pool', '~> 2.3.0'
|
||||
|
||||
# For more information and examples about making a new gem, check out our
|
||||
# guide at: https://bundler.io/guides/creating_gem.html
|
||||
spec.metadata['rubygems_mfa_required'] = 'true'
|
||||
end
|
||||
|
||||
@ -1,11 +1,7 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe RabbitCarrots do
|
||||
it "has a version number" do
|
||||
it 'has a version number' do
|
||||
expect(RabbitCarrots::VERSION).not_to be nil
|
||||
end
|
||||
|
||||
it "does something useful" do
|
||||
expect(false).to eq(true)
|
||||
end
|
||||
end
|
||||
|
||||
@ -1,10 +1,10 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require "rabbit_carrots"
|
||||
require 'rabbit_carrots'
|
||||
|
||||
RSpec.configure do |config|
|
||||
# Enable flags like --only-failures and --next-failure
|
||||
config.example_status_persistence_file_path = ".rspec_status"
|
||||
config.example_status_persistence_file_path = '.rspec_status'
|
||||
|
||||
# Disable RSpec exposing methods globally on `Module` and `main`
|
||||
config.disable_monkey_patching!
|
||||
|
||||
Loading…
Reference in New Issue
Block a user