Module: RailwayIpc

Defined in:

lib/railway_ipc.rb,
lib/railway_ipc/logger.rb,
lib/railway_ipc/handler.rb,
lib/railway_ipc/railtie.rb,
lib/railway_ipc/version.rb,
lib/railway_ipc/response.rb,
lib/railway_ipc/publisher.rb,
lib/railway_ipc/publisher.rb,
lib/railway_ipc/responder.rb,
lib/railway_ipc/handler_store.rb,
lib/railway_ipc/incoming_message.rb,
lib/railway_ipc/rabbitmq/adapter.rb,
lib/railway_ipc/rabbitmq/payload.rb,
lib/railway_ipc/consumer/consumer.rb,
lib/railway_ipc/rpc/client/client.rb,
lib/railway_ipc/rpc/server/server.rb,
lib/railway_ipc/connection_manager.rb,
lib/railway_ipc/unknown_message.pb.rb,
lib/railway_ipc/models/consumed_message.rb,
lib/railway_ipc/unhandled_message_error.rb,
lib/railway_ipc/models/published_message.rb,
lib/railway_ipc/rpc/client/errors/timeout_error.rb,
lib/railway_ipc/consumer/process_incoming_message.rb,
lib/railway_ipc/rpc/client/client_response_handlers.rb,
lib/railway_ipc/rpc/server/server_response_handlers.rb,
lib/railway_ipc/rpc/concerns/error_adapter_configurable.rb,
lib/railway_ipc/rpc/concerns/publish_location_configurable.rb,
lib/railway_ipc/rpc/concerns/message_observation_configurable.rb

Defined Under Namespace

Modules: Messages, RPC, Rabbitmq Classes: Client, ConnectionManager, ConsumedMessage, Consumer, Error, FailedToStoreOutgoingMessage, Handler, HandlerManifest, HandlerStore, IncomingMessage, InvalidProtobuf, Logger, ProcessIncomingMessage, PublishedMessage, Publisher, Railtie, Responder, Response, Server, SingletonPublisher, UnhandledMessageError

Constant Summary

VERSION =

'3.0.0'

Class Method Summary

• .bunny_connection ⇒ Object
• .configure(log_device = $stdout, level = ::Logger::INFO, log_formatter = nil) ⇒ Object
• .logger ⇒ Object
• .spawn ⇒ Object
• .start ⇒ Object

Class Method Details

.bunny_connection ⇒ Object

# File 'lib/railway_ipc.rb', line 46

def self.bunny_connection
  @bunny_connection ||= RailwayIpc::Rabbitmq::Adapter.new(
    exchange_name: 'default',
    options: { automatic_recovery: true }
  ).connection
end

.configure(log_device = $stdout, level = ::Logger::INFO, log_formatter = nil) ⇒ Object

# File 'lib/railway_ipc.rb', line 38

def self.configure(log_device=$stdout, level=::Logger::INFO, log_formatter=nil)
  @logger = RailwayIpc::Logger.new(log_device, level, log_formatter)
end

.logger ⇒ Object

# File 'lib/railway_ipc.rb', line 42

def self.logger
  @logger || RailwayIpc::Logger.new($stdout)
end

.spawn ⇒ Object

# File 'lib/railway_ipc.rb', line 34

def self.spawn
  Sneakers::Spawner.spawn
end

.start ⇒ Object

# File 'lib/railway_ipc.rb', line 30

def self.start
  Rake::Task['sneakers:run'].invoke
end