Sha256: 8fb24a1a7d75769bf48fc87f8eb838ef008d53cfe21db5be34f2f3f0bb2a2415
Contents?: true
Size: 1.21 KB
Versions: 7
Compression:
Stored size: 1.21 KB
Contents
# -*- coding: utf-8 -*-
require "spec_helper"
unless ENV["CI"]
describe "TLS connection to RabbitMQ" do
let(:connection) do
c = Bunny.new(:user => "bunny_gem",
:password => "bunny_password",
:vhost => "bunny_testbed",
:tls => true,
:tls_cert => "spec/tls/client_cert.pem",
:tls_key => "spec/tls/client_key.pem",
:tls_ca_certificates => ["./spec/tls/cacert.pem"])
c.start
c
end
after :all do
connection.close
end
it "provides the same API as a regular connection" do
ch = connection.create_channel
q = ch.queue("", :exclusive => true)
x = ch.default_exchange
x.publish("xyzzy", :routing_key => q.name).
publish("xyzzy", :routing_key => q.name).
publish("xyzzy", :routing_key => q.name).
publish("xyzzy", :routing_key => q.name)
sleep 0.5
q.message_count.should == 4
i = 0
q.subscribe do |delivery_info, _, payload|
i += 1
end
sleep 1.0
i.should == 4
q.message_count.should == 0
ch.close
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems