Module: Artery

Includes:
Backend, Config, Subscriptions
Defined in:
lib/artery/backends/fake.rb,
lib/artery.rb,
lib/artery/sync.rb,
lib/artery/check.rb,
lib/artery/model.rb,
lib/artery/config.rb,
lib/artery/engine.rb,
lib/artery/errors.rb,
lib/artery/worker.rb,
lib/artery/backend.rb,
lib/artery/routing.rb,
lib/artery/version.rb,
lib/artery/publisher.rb,
lib/artery/no_brainer.rb,
lib/artery/subscription.rb,
lib/artery/active_record.rb,
lib/artery/backends/base.rb,
lib/artery/subscriptions.rb,
lib/artery/log_subscriber.rb,
lib/artery/instrumentation.rb,
lib/artery/model/callbacks.rb,
lib/artery/backends/nats_pure.rb,
lib/artery/no_brainer/message.rb,
lib/artery/model/subscriptions.rb,
lib/artery/healthz_subscription.rb,
lib/artery/active_record/message.rb,
lib/artery/active_record/model_info.rb,
lib/artery/worker_healthz_subscription.rb,
lib/artery/no_brainer/subscription_info.rb,
lib/artery/subscription/synchronization.rb,
app/models/concerns/artery/message_model.rb,
lib/artery/subscription/incoming_message.rb,
lib/artery/active_record/subscription_info.rb

Overview

For the test environment

Defined Under Namespace

Modules: ActiveRecord, Backend, Backends, Config, Instrumentation, MessageModel, Model, NoBrainer, Routing, Subscriptions Classes: Check, Engine, Error, ErrorHandler, FormatError, HealthzSubscription, LogSubscriber, Publisher, RequestError, SentryErrorHandler, Subscription, Sync, TimeoutError, Worker, WorkerHealthzSubscription

Constant Summary collapse

VERSION = 
'1.4.3'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.worker ⇒ Object

Returns the value of attribute worker.



45
46
47
 
# File 'lib/artery.rb', line 45

def worker
  @worker
end

Class Method Details

.handle_error(exception) ⇒ Object 



73
74
75
 
# File 'lib/artery/errors.rb', line 73

def handle_error(exception)
  Artery.error_handler.handle exception
end

.handle_signals ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/artery.rb', line 47

def handle_signals
  %w[TERM INT].each do |sig|
    trap(sig) do
      Artery.logger.info "Caught #{sig} signal, exiting..."

      yield if block_given?

      exit
    end
  end
end