1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
# encoding: binary
require File.expand_path('../../../spec_helper', __FILE__)
module AMQ
module Protocol
class Connection
describe Start do
describe '.decode' do
subject do
Start.decode("\x00\t\x00\x00\x00\xFB\tcopyrightS\x00\x00\x00gCopyright (C) 2007-2010 LShift Ltd., Cohesive Financial Technologies LLC., and Rabbit Technologies Ltd.\vinformationS\x00\x00\x005Licensed under the MPL. See http://www.rabbitmq.com/\bplatformS\x00\x00\x00\nErlang/OTP\aproductS\x00\x00\x00\bRabbitMQ\aversionS\x00\x00\x00\x052.2.0\x00\x00\x00\x0EPLAIN AMQPLAIN\x00\x00\x00\x05en_US")
end
its(:version_major) { should == 0 }
its(:version_minor) { should == 9 }
its(:server_properties) { should == {'copyright' => 'Copyright (C) 2007-2010 LShift Ltd., Cohesive Financial Technologies LLC., and Rabbit Technologies Ltd.', 'information' => 'Licensed under the MPL. See http://www.rabbitmq.com/', 'platform' => 'Erlang/OTP', 'product' => 'RabbitMQ', 'version' => '2.2.0'} }
its(:mechanisms) { should == 'PLAIN AMQPLAIN' }
its(:locales) { should == 'en_US' }
end
end
describe StartOk do
describe '.encode' do
it 'encodes the parameters into a MethodFrame' do
client_properties = {:platform => 'Ruby 1.9.2', :product => 'AMQ Client', :information => 'http://github.com/ruby-amqp/amq-client', :version => '0.2.0'}
mechanism = 'PLAIN'
response = "\x00guest\x00guest"
locale = 'en_GB'
method_frame = StartOk.encode(client_properties, mechanism, response, locale)
# the order of the table parts isn't deterministic in Ruby 1.8
method_frame.payload[0, 8].should == "\x00\n\x00\v\x00\x00\x00x"
method_frame.payload.should include("\bplatformS\x00\x00\x00\nRuby 1.9.2")
method_frame.payload.should include("\aproductS\x00\x00\x00\nAMQ Client")
method_frame.payload.should include("\vinformationS\x00\x00\x00&http://github.com/ruby-amqp/amq-client")
method_frame.payload.should include("\aversionS\x00\x00\x00\x050.2.0")
method_frame.payload[-28, 28].should == "\x05PLAIN\x00\x00\x00\f\x00guest\x00guest\x05en_GB"
method_frame.payload.length.should == 156
end
end
end
describe Secure do
describe '.decode' do
subject do
Secure.decode("\x00\x00\x00\x03foo")
end
its(:challenge) { should == 'foo' }
end
end
describe SecureOk do
describe '.encode' do
it 'encodes the parameters as a MethodFrame' do
response = 'bar'
method_frame = SecureOk.encode(response)
method_frame.payload.should == "\x00\x0a\x00\x15\x00\x00\x00\x03bar"
end
end
end
describe Tune do
describe '.decode' do
subject do
Tune.decode("\x00\x00\x00\x02\x00\x00\x00\x00")
end
its(:channel_max) { should == 0 }
its(:frame_max) { should == 131072 }
its(:heartbeat) { should == 0}
end
end
describe TuneOk do
describe '.encode' do
it 'encodes the parameters into a MethodFrame' do
channel_max = 0
frame_max = 65536
heartbeat = 1
method_frame = TuneOk.encode(channel_max, frame_max, heartbeat)
method_frame.payload.should == "\x00\n\x00\x1F\x00\x00\x00\x01\x00\x00\x00\x01"
end
end
end
describe Open do
describe '.encode' do
it 'encodes the parameters into a MethodFrame' do
vhost = '/test'
method_frame = Open.encode(vhost)
method_frame.payload.should == "\x00\n\x00(\x05/test\x00\x00"
end
end
end
describe OpenOk do
describe '.decode' do
subject do
OpenOk.decode("\x00")
end
its(:known_hosts) { should == '' }
end
end
describe Close do
describe '.decode' do
context 'with code 200' do
subject do
Close.decode("\x00\xc8\x07KTHXBAI\x00\x05\x00\x06")
end
its(:reply_code) { should == 200 }
its(:reply_text) { should == 'KTHXBAI' }
its(:class_id) { should == 5 }
its(:method_id) { should == 6 }
end
context 'with an error code' do
it 'returns method frame and lets calling code handle the issue' do
Close.decode("\x01\x38\x08NO_ROUTE\x00\x00")
end
end
end
describe '.encode' do
it 'encodes the parameters into a MethodFrame' do
reply_code = 540
reply_text = 'NOT_IMPLEMENTED'
class_id = 0
method_id = 0
method_frame = Close.encode(reply_code, reply_text, class_id, method_id)
method_frame.payload.should == "\x00\x0a\x002\x02\x1c\x0fNOT_IMPLEMENTED\x00\x00\x00\x00"
end
end
end
describe CloseOk do
describe '.encode' do
it 'encodes a MethodFrame' do
method_frame = CloseOk.encode
method_frame.payload.should == "\x00\n\x003"
end
end
end
end
end
end
|
