class RubyRabbitmqJanus::Tools::Cluster
Manage Janus
instance
Public Class Methods
new()
click to toggle source
Initialize object for managing each instance to Janus
# File lib/rrj/tools/gem/cluster.rb, line 12 def initialize @current_instance = nil end
Public Instance Methods
queue_admin_to(instance = nil)
click to toggle source
Specify a name to admin queue
# File lib/rrj/tools/gem/cluster.rb, line 23 def queue_admin_to(instance = nil) Tools::Config.instance.options['queues']['admin']['to'] + \ "-#{instance.blank? ? @current_instance : instance}" end
queue_to(instance = nil)
click to toggle source
Specify a name to queue
# File lib/rrj/tools/gem/cluster.rb, line 17 def queue_to(instance = nil) Tools::Config.instance.options['queues']['standard']['to'] + \ "-#{instance.blank? ? @current_instance : instance}" end