first steps of integration tests are in place

lib/amqp/failover.rb

@@ -1,6 +1,5 @@
 # encoding: utf-8
 
-require 'amqp'
 require 'yaml'
 
 require 'amqp/failover/basic_client'

spec/integration/simple_spec.rb

@@ -0,0 +1,29 @@
+# encoding: utf-8
+
+require 'spec_helper'
+require 'amqp/server'
+require 'spec_server'
+
+describe "Simple AMQP connection with Failover feature loaded" do
+  
+  before(:all) do
+    @log = SpecServer.log
+  end
+    
+  it "should be connected" do
+    EM.run {
+      @sig = EM.start_server('localhost', 15672, SpecServer)
+      conn = AMQP.connect(:host => 'localhost', :port => 15672)
+      EM.add_timer(0.1) {
+        conn.should be_connected
+        @log.size.should == 3
+        (0..2).each { |i| @log[i][0].should == "send" }
+        @log[0][1].payload.should be_a(AMQP::Protocol::Connection::Start)
+        @log[1][1].payload.should be_a(AMQP::Protocol::Connection::Tune)
+        @log[2][1].payload.should be_a(AMQP::Protocol::Connection::OpenOk)
+        EM.stop
+      }
+    }
+  end
+  
+end

spec/spec_helper.rb

@@ -4,6 +4,11 @@ $LOAD_PATH.unshift File.join(File.dirname(__FILE__), '..', 'lib')
 
 # require stuff
 require 'rubygems'
+begin
+  require 'mq'
+rescue Object => e
+  require 'amqp'
+end
 require 'amqp/failover'
 require 'rspec'
 require 'rspec/autorun'

spec/spec_server.rb

@@ -0,0 +1,18 @@
+# encoding: utf-8
+
+module SpecServer
+  include AMQP::Server
+  
+  class << self
+    def log
+      @log ||= []
+    end
+    attr_writer :log
+  end
+  
+  def log(*args)
+    SpecServer.log << args
+    # silence Output
+  end
+  
+end