Module: Hutch
- Defined in:
- lib/hutch.rb,
lib/hutch/cli.rb,
lib/hutch/broker.rb,
lib/hutch/config.rb,
lib/hutch/worker.rb,
lib/hutch/logging.rb,
lib/hutch/message.rb,
lib/hutch/version.rb,
lib/hutch/consumer.rb,
lib/hutch/exceptions.rb,
lib/hutch/error_handlers.rb,
lib/hutch/error_handlers/logger.rb,
lib/hutch/error_handlers/sentry.rb
Defined Under Namespace
Modules: Config, Consumer, ErrorHandlers, Logging
Classes: AuthenticationError, Broker, CLI, ConnectionError, Message, PublishError, UnknownAttributeError, Worker, WorkerSetupError
Constant Summary
collapse
- VERSION =
'0.10.0'.freeze
Class Method Summary
collapse
Class Method Details
.broker ⇒ Object
40
41
42
|
# File 'lib/hutch.rb', line 40
def self.broker
@broker
end
|
.connect(options = {}, config = Hutch::Config) ⇒ Object
32
33
34
35
36
37
38
|
# File 'lib/hutch.rb', line 32
def self.connect(options = {}, config = Hutch::Config)
unless connected?
@broker = Hutch::Broker.new(config)
@broker.connect(options)
@connected = true
end
end
|
.connected? ⇒ Boolean
44
45
46
|
# File 'lib/hutch.rb', line 44
def self.connected?
@connected
end
|
.consumers ⇒ Object
16
17
18
|
# File 'lib/hutch.rb', line 16
def self.consumers
@consumers ||= []
end
|
.global_properties ⇒ Object
28
29
30
|
# File 'lib/hutch.rb', line 28
def self.global_properties
@global_properties ||= {}
end
|
.global_properties=(properties) ⇒ Object
24
25
26
|
# File 'lib/hutch.rb', line 24
def self.global_properties=(properties)
@global_properties = properties
end
|
.publish(*args) ⇒ Object
48
49
50
|
# File 'lib/hutch.rb', line 48
def self.publish(*args)
broker.publish(*args)
end
|
.register_consumer(consumer) ⇒ Object
12
13
14
|
# File 'lib/hutch.rb', line 12
def self.register_consumer(consumer)
self.consumers << consumer
end
|