Sha256: 1ed2a03b117f8c2c20d8f8a520b2cac77231c434398e25634db85c73b6e35a93
Contents?: true
Size: 1.19 KB
Versions: 14
Compression:
Stored size: 1.19 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
14 entries across 14 versions & 1 rubygems