Sha256: 46fde230602d81fec319119351fe32a3f8102fcc2f019a693a84942791f90246
Contents?: true
Size: 1.61 KB
Versions: 36
Compression:
Stored size: 1.61 KB
Contents
# encoding: binary
require "spec_helper"
require "stringio"
# We need to require AMQ-Protocol manually.
# In the library this is required in the file
# amq/client.rb, but this is a unit test and
# we don't want to mess around with unecessary
# dependencies.
require "amq/protocol/client"
require "amq/protocol/frame"
# We have to use Kernel#load so extensions to the
# Logging module from client.rb will be overridden.
load "amq/client/framing/io/frame.rb"
describe AMQ::Client::Framing::IO do
subject do
AMQ::Client::Framing::IO::Frame
end
# Created by:
# frame = AMQ::Protocol::Queue::Declare.encode(1, "tasks", false, false, false, false, {})
# frame.encode
# frame.payload
before do
data = ["\x01\x00\x00\x00\x00\x00\b"]
data << "\x00\n\x00(\x01/\x00\x00"
data << "\xCE"
@io = StringIO.new(data.join)
subject.stub(:decode_header).with(data.first).and_return([1, 0, data[1].bytesize])
end
it "should be able to decode frame type" do
subject.decode(@io).should be_kind_of(AMQ::Protocol::MethodFrame)
end
it "should be able to decode channel" do
subject.decode(@io).channel.should eql(0)
end
it "should be able to decode payload" do
subject.decode(@io).payload.should eql("\x00\n\x00(\x01/\x00\x00")
end
it "should raise an error if the frame length is miscalculated" do
pending "How to do that with socket?"
end
it "should raise an error if the frame doesn't end with FINAL_OCTET" do
data = @io.read[0..-2] + "too long" + "\xCE"
io = StringIO.new(data)
lambda { subject.decode(io) }.should raise_error(AMQ::Client::NoFinalOctetError)
end
end
Version data entries
36 entries across 36 versions & 1 rubygems