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