module Circuitry
Constants
- VERSION
Public Class Methods
flush()
click to toggle source
# File lib/circuitry.rb, line 48 def flush Processors.constants.each do |const| Processors.const_get(const).flush end end
publish(topic_name, object, options = {})
click to toggle source
# File lib/circuitry.rb, line 40 def publish(topic_name, object, options = {}) Publisher.new(options).publish(topic_name, object) end
publisher_config() { |pub_config| ... }
click to toggle source
# File lib/circuitry.rb, line 30 def publisher_config @pub_config ||= Config::PublisherSettings.new yield @pub_config if block_given? @pub_config end
publisher_config=(options)
click to toggle source
# File lib/circuitry.rb, line 36 def publisher_config=(options) @pub_config = Config::PublisherSettings.new(options) end
subscribe(options = {}, &block)
click to toggle source
# File lib/circuitry.rb, line 44 def subscribe(options = {}, &block) Subscriber.new(options).subscribe(&block) end
subscriber_config() { |sub_config| ... }
click to toggle source
# File lib/circuitry.rb, line 20 def subscriber_config @sub_config ||= Config::SubscriberSettings.new yield @sub_config if block_given? @sub_config end
subscriber_config=(options)
click to toggle source
# File lib/circuitry.rb, line 26 def subscriber_config=(options) @sub_config = Config::SubscriberSettings.new(options) end