Sha256: fa7d4737d6e06fd55997e943e14fa6da82ff990324455935da41bb83c1ed1050
Contents?: true
Size: 1.17 KB
Versions: 27
Compression:
Stored size: 1.17 KB
Contents
# -*- encoding: utf-8; mode: ruby -*-
$LOAD_PATH.unshift File.expand_path("../lib", __FILE__)
require 'bundler'
Bundler.setup(:default, :test)
require "effin_utf8"
require "bunny"
require "rabbitmq/http/client"
require "amq/protocol/version"
puts "Using Ruby #{RUBY_VERSION}, amq-protocol #{AMQ::Protocol::VERSION}"
module RabbitMQ
module Control
RABBITMQ_NODENAME = ENV['RABBITMQ_NODENAME'] || 'rabbit'
def rabbitmq_pid
$1.to_i if `rabbitmqctl -n #{RABBITMQ_NODENAME} status` =~ /\{pid,(\d+)\}/
end
def start_rabbitmq(delay = 1.0)
# this is Homebrew-specific :(
`RABBITMQ_NODENAME=#{RABBITMQ_NODENAME} rabbitmq-server > /dev/null 2>&1 &`; sleep(delay)
end
def stop_rabbitmq(pid = rabbitmq_pid, delay = 1.0)
`rabbitmqctl -n #{RABBITMQ_NODENAME} stop`; sleep(delay)
end
def kill_rabbitmq(pid = rabbitmq_pid, delay = 1.0)
# tango is down, tango is down!
Process.kill("KILL", pid); sleep(delay)
end
end
end
module PlatformDetection
def mri?
!defined?(RUBY_ENGINE) || (defined?(RUBY_ENGINE) && ("ruby" == RUBY_ENGINE))
end
def rubinius?
defined?(RUBY_ENGINE) && (RUBY_ENGINE == 'rbx')
end
end
Version data entries
27 entries across 27 versions & 1 rubygems