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/testing.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/locks/memory.rb,
lib/circuitry/provisioning.rb,
lib/circuitry/services/sns.rb,
lib/circuitry/services/sqs.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/config/file_loader.rb,
lib/circuitry/processors/batcher.rb,
lib/circuitry/processors/threader.rb,
lib/circuitry/config/shared_settings.rb,
lib/circuitry/provisioning/provisioner.rb,
lib/circuitry/config/publisher_settings.rb,
lib/circuitry/config/subscriber_settings.rb,
lib/circuitry/provisioning/queue_creator.rb,
lib/circuitry/provisioning/topic_creator.rb,
lib/circuitry/provisioning/subscription_creator.rb

Defined Under Namespace

Modules: Concerns, Config, Locks, Middleware, Processor, Processors, Provisioning, Services Classes: CLI, ConfigError, Message, NotSupportedError, PublishError, Publisher, Queue, Railtie, SubscribeError, Subscriber, Topic

Constant Summary collapse

VERSION = 
'3.2.0'

Class Method Summary collapse

Class Method Details

.flush ⇒ Object 



48
49
50
51
52
 
# 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 = {}) ⇒ Object 



40
41
42
 
# File 'lib/circuitry.rb', line 40

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

.publisher_config {|@pub_config| ... } ⇒ Object

Yields:

  • (@pub_config) 


30
31
32
33
34
 
# 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) ⇒ Object 



36
37
38
 
# File 'lib/circuitry.rb', line 36

def publisher_config=(options)
  @pub_config = Config::PublisherSettings.new(options)
end

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



44
45
46
 
# File 'lib/circuitry.rb', line 44

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

.subscriber_config {|@sub_config| ... } ⇒ Object

Yields:

  • (@sub_config) 


20
21
22
23
24
 
# 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) ⇒ Object 



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

def subscriber_config=(options)
  @sub_config = Config::SubscriberSettings.new(options)
end