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