module Circuitry

# File lib/circuitry.rb, line 48
def flush
  Processors.constants.each do |const|
    Processors.const_get(const).flush
  end
end

# File lib/circuitry.rb, line 40
def publish(topic_name, object, options = {})
  Publisher.new(options).publish(topic_name, object)
end

# File lib/circuitry.rb, line 30
def publisher_config
  @pub_config ||= Config::PublisherSettings.new
  yield @pub_config if block_given?
  @pub_config
end

# File lib/circuitry.rb, line 36
def publisher_config=(options)
  @pub_config = Config::PublisherSettings.new(options)
end

# File lib/circuitry.rb, line 44
def subscribe(options = {}, &block)
  Subscriber.new(options).subscribe(&block)
end

# File lib/circuitry.rb, line 20
def subscriber_config
  @sub_config ||= Config::SubscriberSettings.new
  yield @sub_config if block_given?
  @sub_config
end

# File lib/circuitry.rb, line 26
def subscriber_config=(options)
  @sub_config = Config::SubscriberSettings.new(options)
end