Sha256: 9f5b7d4a9f140aa4a3cf46c36cb22cd6899ccf0072b03e00580b575a3dda8ea9
Contents?: true
Size: 1.17 KB
Versions: 40
Compression:
Stored size: 1.17 KB
Contents
require "rabbitmq/http/client"
class GusSubscriber < ActionSubscriber::Base
def spoke
$messages << payload
end
end
describe "Automatically reconnect on connection failure", :integration => true, :slow => true do
let(:draw_routes) do
::ActionSubscriber.draw_routes do
default_routes_for GusSubscriber
end
end
let(:http_client) { RabbitMQ::HTTP::Client.new("http://127.0.0.1:15672") }
let(:subscriber) { GusSubscriber }
it "reconnects when a connection drops" do
::ActionSubscriber::start_subscribers!
::ActivePublisher.publish("gus.spoke", "First", "events")
verify_expectation_within(5.0) do
expect($messages).to eq(Set.new(["First"]))
end
close_all_connections!
sleep 5.0
verify_expectation_within(5.0) do
expect(::ActionSubscriber::RabbitConnection.with_connection{|connection| connection.open?}).to eq(true)
end
::ActivePublisher.publish("gus.spoke", "Second", "events")
verify_expectation_within(5.0) do
expect($messages).to eq(Set.new(["First", "Second"]))
end
end
def close_all_connections!
http_client.list_connections.each do |conn_info|
http_client.close_connection(conn_info.name)
end
end
end
Version data entries
40 entries across 40 versions & 1 rubygems