Sha256: 1547dd302cbc1bc117ee02f3dfd0f180966bc626253cf2f768d499d69531b2a0
Contents?: true
Size: 1.32 KB
Versions: 3
Compression:
Stored size: 1.32 KB
Contents
# frozen_string_literal: true require 'railway_ipc/version' require 'sneakers' require 'bunny' require 'active_record' require 'railway_ipc/version' require 'railway_ipc/logger' require 'railway_ipc/unhandled_message_error' require 'railway_ipc/response' require 'railway_ipc/rabbitmq/payload' require 'railway_ipc/unknown_message.pb' require 'railway_ipc/rabbitmq/adapter' require 'railway_ipc/handler' require 'railway_ipc/handler_store' require 'railway_ipc/incoming_message' require 'railway_ipc/publisher' require 'railway_ipc/responder' require 'railway_ipc/rpc/rpc' require 'railway_ipc/consumer/consumer' require 'railway_ipc/consumer/process_incoming_message' require 'railway_ipc/models/published_message' require 'railway_ipc/models/consumed_message' require 'railway_ipc/railtie' if defined?(Rails) require 'railway_ipc/errors' module RailwayIpc def self.start Rake::Task['sneakers:run'].invoke end def self.configure(logger: ::Logger.new(STDOUT)) @logger = RailwayIpc::Logger.new(logger) end def self.logger @logger || RailwayIpc::Logger.new(::Logger.new(STDOUT)) end def self.bunny_logger logger.logger end def self.bunny_connection @bunny_connection ||= RailwayIpc::Rabbitmq::Adapter.new( exchange_name: 'default', options: { automatic_recovery: true } ).connection end end
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
railway-ipc-1.1.0 | lib/railway_ipc.rb |
railway-ipc-1.0.1 | lib/railway_ipc.rb |
railway-ipc-1.0.0 | lib/railway_ipc.rb |