module Hutch

broker() click to toggle source

# File lib/hutch.rb, line 57
def self.broker
  @broker
end

connect(options = {}, config = Hutch::Config) click to toggle source

Connects to broker, if not yet connected.

@param options [Hash] Connection options @param config [Hash] Configuration @option options [Boolean] :enable_http_api_use

# File lib/hutch.rb, line 44
def self.connect(options = {}, config = Hutch::Config)
  @@connection_mutex.synchronize do
    unless connected?
      @broker = Hutch::Broker.new(config)
      @broker.connect(options)
    end
  end
end

connected?() click to toggle source

@return [Boolean]

# File lib/hutch.rb, line 62
def self.connected?
  broker && broker.connection && broker.connection.open?
end

consumers() click to toggle source

# File lib/hutch.rb, line 23
def self.consumers
  @consumers ||= []
end

disconnect() click to toggle source

# File lib/hutch.rb, line 53
def self.disconnect
  @broker.disconnect if @broker
end

global_properties() click to toggle source

# File lib/hutch.rb, line 35
def self.global_properties
  @global_properties ||= {}
end

global_properties=(properties) click to toggle source

# File lib/hutch.rb, line 31
def self.global_properties=(properties)
  @global_properties = properties
end

logger() click to toggle source

# File lib/hutch.rb, line 27
def self.logger
  Hutch::Logging.logger
end

publish(*args) click to toggle source

# File lib/hutch.rb, line 66
def self.publish(*args)
  broker.publish(*args)
end

register_consumer(consumer) click to toggle source

# File lib/hutch.rb, line 19
def self.register_consumer(consumer)
  self.consumers << consumer
end

Constants

Public Class Methods