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/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, ConsumedMessage, Consumer, Error, FailedToStoreOutgoingMessage, Handler, HandlerManifest, HandlerStore, IncomingMessage, InvalidProtobuf, Logger, ProcessIncomingMessage, PublishedMessage, Publisher, Railtie, Responder, Response, Server, SingletonPublisher, UnhandledMessageError
Constant Summary
collapse
- VERSION =
'2.0.1'
Class Method Summary
collapse
Class Method Details
.bunny_connection ⇒ Object
40
41
42
43
44
45
|
# File 'lib/railway_ipc.rb', line 40
def self.bunny_connection
@bunny_connection ||= RailwayIpc::Rabbitmq::Adapter.new(
exchange_name: 'default',
options: { automatic_recovery: true }
).connection
end
|
32
33
34
|
# File 'lib/railway_ipc.rb', line 32
def self.configure(log_device=STDOUT, level=::Logger::INFO, log_formatter=nil)
@logger = RailwayIpc::Logger.new(log_device, level, log_formatter)
end
|
.logger ⇒ Object
36
37
38
|
# File 'lib/railway_ipc.rb', line 36
def self.logger
@logger || RailwayIpc::Logger.new(STDOUT)
end
|
.start ⇒ Object
28
29
30
|
# File 'lib/railway_ipc.rb', line 28
def self.start
Rake::Task['sneakers:run'].invoke
end
|