Class: Circuitry::Configuration
- Inherits:
-
Object
- Object
- Circuitry::Configuration
- Includes:
- Virtus::Model
- Defined in:
- lib/circuitry/configuration.rb
Instance Method Summary collapse
- #aws_options ⇒ Object
- #publish_async_strategy=(value) ⇒ Object
- #publisher_middleware {|@publisher_middleware| ... } ⇒ Object
- #subscribe_async_strategy=(value) ⇒ Object
- #subscriber_dead_letter_queue_name ⇒ Object
- #subscriber_middleware {|@subscriber_middleware| ... } ⇒ Object
Instance Method Details
#aws_options ⇒ Object
49 50 51 52 53 54 55 |
# File 'lib/circuitry/configuration.rb', line 49 def { access_key_id: access_key, secret_access_key: secret_key, region: region } end |
#publish_async_strategy=(value) ⇒ Object
23 24 25 26 |
# File 'lib/circuitry/configuration.rb', line 23 def publish_async_strategy=(value) validate(value, Publisher.async_strategies) super end |
#publisher_middleware {|@publisher_middleware| ... } ⇒ Object
43 44 45 46 47 |
# File 'lib/circuitry/configuration.rb', line 43 def publisher_middleware @publisher_middleware ||= Circuitry::Middleware::Chain.new yield @publisher_middleware if block_given? @publisher_middleware end |
#subscribe_async_strategy=(value) ⇒ Object
28 29 30 31 |
# File 'lib/circuitry/configuration.rb', line 28 def subscribe_async_strategy=(value) validate(value, Subscriber.async_strategies) super end |
#subscriber_dead_letter_queue_name ⇒ Object
33 34 35 |
# File 'lib/circuitry/configuration.rb', line 33 def subscriber_dead_letter_queue_name super || "#{subscriber_queue_name}-failures" end |
#subscriber_middleware {|@subscriber_middleware| ... } ⇒ Object
37 38 39 40 41 |
# File 'lib/circuitry/configuration.rb', line 37 def subscriber_middleware @subscriber_middleware ||= Circuitry::Middleware::Chain.new yield @subscriber_middleware if block_given? @subscriber_middleware end |