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