Sha256: cb85b93df68324f737318604ec013e6313651d1288d82bc4b68ce230c4571b09
Contents?: true
Size: 911 Bytes
Versions: 15
Compression:
Stored size: 911 Bytes
Contents
# -*- coding: utf-8 -*-
require "spec_helper"
unless ENV["CI"]
describe "Message framing implementation" do
let(:connection) do
c = Bunny.new(:user => "bunny_gem",
:password => "bunny_password",
:vhost => "bunny_testbed",
:port => ENV.fetch("RABBITMQ_PORT", 5672))
c.start
c
end
after :each do
connection.close if connection.open?
end
context "with payload 272179 bytes in size" do
it "successfully frames the message" do
ch = connection.create_channel
q = ch.queue("", :exclusive => true)
x = ch.default_exchange
as = ("a" * 272179)
x.publish(as, :routing_key => q.name, :persistent => true)
sleep(1)
q.message_count.should == 1
_, _, payload = q.pop
payload.bytesize.should == as.bytesize
ch.close
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems