Module: Eventboss
- Defined in:
- lib/eventboss.rb,
lib/eventboss/queue.rb,
lib/eventboss/logger.rb,
lib/eventboss/runner.rb,
lib/eventboss/sender.rb,
lib/eventboss/worker.rb,
lib/eventboss/fetcher.rb,
lib/eventboss/logging.rb,
lib/eventboss/version.rb,
lib/eventboss/launcher.rb,
lib/eventboss/listener.rb,
lib/eventboss/publisher.rb,
lib/eventboss/sns_client.rb,
lib/eventboss/long_poller.rb,
lib/eventboss/safe_thread.rb,
lib/eventboss/unit_of_work.rb,
lib/eventboss/configuration.rb,
lib/eventboss/queue_listener.rb,
lib/eventboss/instrumentation.rb,
lib/eventboss/error_handlers/logger.rb,
lib/eventboss/error_handlers/airbrake.rb
Defined Under Namespace
Modules: ErrorHandlers, Instrumentation, Listener, Logging, SafeThread
Classes: Configuration, Fetcher, Launcher, Logger, LongPoller, NotConfigured, Publisher, Queue, QueueListener, Railtie, Runner, Sender, SnsClient, UnitOfWork, Worker
Constant Summary
collapse
- Shutdown =
Class.new(StandardError)
- VERSION =
"1.1.1"
Class Method Summary
collapse
Class Method Details
.configuration ⇒ Object
68
69
70
|
# File 'lib/eventboss.rb', line 68
def configuration
@_configuration ||= Configuration.new
end
|
64
65
66
|
# File 'lib/eventboss.rb', line 64
def configure
yield configuration if block_given?
end
|
.env ⇒ Object
60
61
62
|
# File 'lib/eventboss.rb', line 60
def env
@env ||= ENV['EVENTBUS_ENV'] || ENV['RAILS_ENV'] || ENV['RACK_ENV']
end
|
.publisher(event_name, opts = {}) ⇒ Object
37
38
39
|
# File 'lib/eventboss.rb', line 37
def publisher(event_name, opts = {})
Publisher.new(event_name, configuration.sns_client, configuration, opts)
end
|
.sender(event_name, destination_app, options = {}) ⇒ Object
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
# File 'lib/eventboss.rb', line 41
def sender(event_name, destination_app, options = {})
queue_name = Queue.build_name(
destination: destination_app,
source: configuration.eventboss_app_name,
event: event_name,
env: env,
generic: options[:generic]
)
Sender.new(
client: configuration.sqs_client,
queue: Queue.new(queue_name)
)
end
|