class Rodent::Goliath::Plugin
Public Class Methods
new(address, port, config, status, logger)
click to toggle source
# File lib/rodent/goliath/plugin.rb, line 8 def initialize(address, port, config, status, logger) @port = port @status = status @config = config @logger = logger end
Public Instance Methods
run(connection_string = 'amqp://guest:guest@localhost', pool_size = 50)
click to toggle source
# File lib/rodent/goliath/plugin.rb, line 15 def run(connection_string = 'amqp://guest:guest@localhost', pool_size = 50) @config['amqp'] = AMQP.connect(connection_string) @config['channels'] = EM::Synchrony::ConnectionPool.new(size: pool_size) do AMQP::Channel.new(@config['amqp']) end end