Sha256: 2526f3b2701963d5ba110838565dd5dd20c05c4c5de433abb8257bac63754a6c
Contents?: true
Size: 1.14 KB
Versions: 24
Compression:
Stored size: 1.14 KB
Contents
# encoding: utf-8
require 'spec_helper'
require 'integration/eventmachine/spec_helper'
#
# We assume that default connection settings (amqp://guest:guest@localhost:5672/) should work
#
describe AMQ::Client::EventMachineClient, "Connection.Start" do
include EventedSpec::SpecHelper
default_timeout 0.5
context "with valid credentials" do
it "should trigger the callback" do
em do
AMQ::Client::EventMachineClient.connect do |client|
done
end
end
end
end
context "with invalid credentials" do
context "when given an errback" do
it "should trigger the errback" do
em do
AMQ::Client::EventMachineClient.connect(:port => 12938, :on_tcp_connection_failure => proc { done }) do |client|
raise "This callback should never happen"
end
end
end
end
context "when given no errback" do
it "should raise an error" do
expect {
em do
AMQ::Client::EventMachineClient.connect(:port => 12938) { }
done(0.5)
end
}.to raise_error(AMQ::Client::TCPConnectionFailed)
end
end
end
end
Version data entries
24 entries across 24 versions & 1 rubygems