Class: QueueBus::Config

Inherits:
Object
  • Object
show all
Defined in:
lib/queue_bus/config.rb

Instance Method Summary collapse

Instance Method Details

#adapter ⇒ Object 



16
17
18
19
 
# File 'lib/queue_bus/config.rb', line 16

def adapter
  return @adapter_instance if @adapter_instance
  raise "no adapter has been set"
end

#adapter=(val) ⇒ Object 



3
4
5
6
7
8
9
10
11
12
13
14
 
# File 'lib/queue_bus/config.rb', line 3

def adapter=val
  raise "Adapter already set to #{@adapter_instance.class.name}" if @adapter_instance
  if val.is_a?(Class)
    @adapter_instance = name_or_klass.new
  elsif val.is_a?(::QueueBus::Adapters::Base)
    @adapter_instance = val
  else
    class_name = ::QueueBus::Util.classify(val)
    @adapter_instance = ::QueueBus::Util.constantize("::QueueBus::Adapters::#{class_name}").new
  end
  @adapter_instance
end

#before_publish=(proc) ⇒ Object 



66
67
68
 
# File 'lib/queue_bus/config.rb', line 66

def before_publish=(proc)
  @before_publish_callback = proc
end

#before_publish_callback(attributes) ⇒ Object 



70
71
72
73
74
 
# File 'lib/queue_bus/config.rb', line 70

def before_publish_callback(attributes)
  if @before_publish_callback
    @before_publish_callback.call(attributes)
  end
end

#default_app_key ⇒ Object 



30
31
32
 
# File 'lib/queue_bus/config.rb', line 30

def default_app_key
  @default_app_key
end

#default_app_key=(val) ⇒ Object 



26
27
28
 
# File 'lib/queue_bus/config.rb', line 26

def default_app_key=val
  @default_app_key = Application.normalize(val)
end

#default_queue ⇒ Object 



38
39
40
 
# File 'lib/queue_bus/config.rb', line 38

def default_queue
  @default_queue
end

#default_queue=(val) ⇒ Object 



34
35
36
 
# File 'lib/queue_bus/config.rb', line 34

def default_queue=val
  @default_queue = val
end

#hostname ⇒ Object 



58
59
60
 
# File 'lib/queue_bus/config.rb', line 58

def hostname
  @hostname ||= `hostname 2>&1`.strip.sub(/.local/,'')
end

#hostname=(val) ⇒ Object 



62
63
64
 
# File 'lib/queue_bus/config.rb', line 62

def hostname=val
  @hostname = val
end

#incoming_queue ⇒ Object 



54
55
56
 
# File 'lib/queue_bus/config.rb', line 54

def incoming_queue
  @incoming_queue ||= "bus_incoming"
end

#incoming_queue=(val) ⇒ Object 



50
51
52
 
# File 'lib/queue_bus/config.rb', line 50

def incoming_queue=val
  @incoming_queue = val
end

#local_mode ⇒ Object 



46
47
48
 
# File 'lib/queue_bus/config.rb', line 46

def local_mode
  @local_mode
end

#local_mode=(value) ⇒ Object 



42
43
44
 
# File 'lib/queue_bus/config.rb', line 42

def local_mode=value
  @local_mode = value
end

#log_application(message) ⇒ Object 



84
85
86
87
88
89
 
# File 'lib/queue_bus/config.rb', line 84

def log_application(message)
  if logger
    time = Time.now.strftime('%H:%M:%S %Y-%m-%d')
    logger.info("** [#{time}] #$$: QueueBus #{message}")
  end
end

#log_worker(message) ⇒ Object 



91
92
93
94
95
96
 
# File 'lib/queue_bus/config.rb', line 91

def log_worker(message)
  if ENV['LOGGING'] || ENV['VERBOSE'] || ENV['VVERBOSE']
    time = Time.now.strftime('%H:%M:%S %Y-%m-%d')
    puts "** [#{time}] #$$: #{message}"
  end
end

#logger ⇒ Object 



76
77
78
 
# File 'lib/queue_bus/config.rb', line 76

def logger
  @logger
end

#logger=(val) ⇒ Object 



80
81
82
 
# File 'lib/queue_bus/config.rb', line 80

def logger=val
  @logger = val
end

#redis(&block) ⇒ Object 



21
22
23
24
 
# File 'lib/queue_bus/config.rb', line 21

def redis(&block)
  # TODO: could allow setting for non-redis adapters
  adapter.redis(&block)
end