Module: Mantle
- Defined in:
- lib/mantle.rb,
lib/mantle/cli.rb,
lib/mantle/error.rb,
lib/mantle/logger.rb,
lib/mantle/message.rb,
lib/mantle/railtie.rb,
lib/mantle/testing.rb,
lib/mantle/version.rb,
lib/mantle/catch_up.rb,
lib/mantle/local_redis.rb,
lib/mantle/message_bus.rb,
lib/mantle/configuration.rb,
lib/mantle/message_router.rb,
lib/mantle/message_handler.rb,
lib/mantle/message_handlers.rb,
lib/mantle/workers/process_worker.rb,
lib/mantle/workers/message_handler_worker.rb,
lib/mantle/workers/catch_up_cleanup_worker.rb,
lib/generators/mantle/install/install_generator.rb
Defined Under Namespace
Modules: Generators, Workers
Classes: CLI, CatchUp, Configuration, Error, LocalRedis, Logger, Message, MessageBus, MessageHandler, MessageHandlers, MessageRouter, Railtie, TestMessage
Constant Summary
collapse
- VERSION =
'2.3.1'
Class Attribute Summary collapse
Class Method Summary
collapse
Class Attribute Details
.configuration ⇒ Object
Returns the value of attribute configuration.
30
31
32
|
# File 'lib/mantle.rb', line 30
def configuration
@configuration
end
|
Class Method Details
.channels ⇒ Object
45
46
47
|
# File 'lib/mantle.rb', line 45
def self.channels
configuration.message_handlers.channels
end
|
.clear_all ⇒ Object
9
10
11
|
# File 'lib/mantle/testing.rb', line 9
def clear_all
@messages = []
end
|
33
34
35
36
|
# File 'lib/mantle.rb', line 33
def self.configure
self.configuration ||= Configuration.new
yield configuration if block_given?
end
|
.logger ⇒ Object
49
50
51
|
# File 'lib/mantle.rb', line 49
def self.logger
configuration.logger
end
|
.messages ⇒ Object
5
6
7
|
# File 'lib/mantle/testing.rb', line 5
def messages
@messages ||= []
end
|
.receive_message(channel, message) ⇒ Object
38
39
40
41
42
43
|
# File 'lib/mantle.rb', line 38
def self.receive_message(channel, message)
Mantle.logger.debug("Message received on channel: #{channel}")
Mantle.logger.debug("Mantle message: #{message}")
self.configuration.message_handlers.receive_message channel, message
end
|