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/responder.rb,
lib/railway_ipc/handler_store.rb,
lib/railway_ipc/incoming_message.rb,
lib/railway_ipc/message_decoders.rb,
lib/railway_ipc/message_encoders.rb,
lib/railway_ipc/outgoing_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: MessageDecoders, MessageEncoders, Messages, RPC, Rabbitmq
Classes: Client, ConnectionManager, ConsumedMessage, Consumer, Error, FailedToStoreOutgoingMessage, Handler, HandlerManifest, HandlerStore, IncomingMessage, InvalidProtobuf, Logger, OutgoingMessage, ProcessIncomingMessage, PublishedMessage, Publisher, Railtie, Responder, Response, Server, UnhandledMessageError
Constant Summary
collapse
- VERSION =
'5.1.0'
Class Method Summary
collapse
Class Method Details
.bunny_connection ⇒ Object
49
50
51
52
53
54
|
# File 'lib/railway_ipc.rb', line 49
def self.bunny_connection
@bunny_connection ||= RailwayIpc::Rabbitmq::Adapter.new(
exchange_name: 'default',
options: { automatic_recovery: true }
).connection
end
|
41
42
43
|
# File 'lib/railway_ipc.rb', line 41
def self.configure(log_device=$stdout, level=::Logger::INFO, log_formatter=nil)
@logger = RailwayIpc::Logger.new(log_device, level, log_formatter)
end
|
.logger ⇒ Object
45
46
47
|
# File 'lib/railway_ipc.rb', line 45
def self.logger
@logger || RailwayIpc::Logger.new($stdout)
end
|
.spawn ⇒ Object
37
38
39
|
# File 'lib/railway_ipc.rb', line 37
def self.spawn
Sneakers::Spawner.spawn
end
|
.start ⇒ Object
33
34
35
|
# File 'lib/railway_ipc.rb', line 33
def self.start
Rake::Task['sneakers:run'].invoke
end
|