Module: Circuitry

Defined in:

lib/circuitry.rb,
lib/circuitry/cli.rb,
lib/circuitry/queue.rb,
lib/circuitry/topic.rb,
lib/circuitry/message.rb,
lib/circuitry/railtie.rb,
lib/circuitry/version.rb,
lib/circuitry/processor.rb,
lib/circuitry/publisher.rb,
lib/circuitry/locks/base.rb,
lib/circuitry/locks/noop.rb,
lib/circuitry/subscriber.rb,
lib/circuitry/locks/redis.rb,
lib/circuitry/provisioner.rb,
lib/circuitry/locks/memory.rb,
lib/circuitry/services/sns.rb,
lib/circuitry/services/sqs.rb,
lib/circuitry/configuration.rb,
lib/circuitry/queue_creator.rb,
lib/circuitry/topic_creator.rb,
lib/circuitry/concerns/async.rb,
lib/circuitry/locks/memcache.rb,
lib/circuitry/middleware/chain.rb,
lib/circuitry/middleware/entry.rb,
lib/circuitry/processors/forker.rb,
lib/circuitry/processors/batcher.rb,
lib/circuitry/processors/threader.rb,
lib/circuitry/subscription_creator.rb

Defined Under Namespace

Modules: Concerns, Locks, Middleware, Processor, Processors, Services Classes: CLI, Configuration, Message, NotSupportedError, Provisioner, PublishError, Publisher, Queue, QueueCreator, Railtie, SubscribeError, Subscriber, SubscriptionCreator, Topic, TopicCreator

Constant Summary

VERSION =

'2.1.1'

Class Method Summary

• .config(&block) ⇒ Object
• .flush ⇒ Object
• .publish(topic_name, object, options = {}) ⇒ Object
• .subscribe(options = {}, &block) ⇒ Object

Class Method Details

.config(&block) ⇒ Object

# File 'lib/circuitry.rb', line 18

def self.config(&block)
  @config ||= Configuration.new
  block.call(@config) if block_given?
  @config
end

.flush ⇒ Object

# File 'lib/circuitry.rb', line 32

def self.flush
  Processors.constants.each do |const|
    Processors.const_get(const).flush
  end
end

.publish(topic_name, object, options = {}) ⇒ Object

# File 'lib/circuitry.rb', line 24

def self.publish(topic_name, object, options = {})
  Publisher.new(options).publish(topic_name, object)
end

.subscribe(options = {}, &block) ⇒ Object

# File 'lib/circuitry.rb', line 28

def self.subscribe(options = {}, &block)
  Subscriber.new(options).subscribe(&block)
end