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