@@ -18,7 +18,7 @@ describe AMQProxy::Server do
1818 ch.basic_publish_confirm " foobar" , " non-existing"
1919 end
2020 end
21- sleep 0.1
21+ sleep 0.1 .seconds
2222 server.upstream_connections.should eq 1
2323 end
2424 end
@@ -55,7 +55,7 @@ describe AMQProxy::Server do
5555 queue.publish_confirm(message_payload)
5656 end
5757 end
58- sleep 0.1
58+ sleep 0.1 .seconds
5959
6060 AMQP ::Client .start(proxy_url) do |conn |
6161 channel = conn.channel
@@ -66,7 +66,7 @@ describe AMQProxy::Server do
6666 num_received_messages += 1
6767 end
6868 end
69- sleep 0.1
69+ sleep 0.1 .seconds
7070 end
7171
7272 num_received_messages.should eq num_messages_to_publish
@@ -84,7 +84,7 @@ describe AMQProxy::Server do
8484 server.client_connections.should eq 1
8585 server.upstream_connections.should eq 2
8686 end
87- sleep 0.1
87+ sleep 0.1 .seconds
8888 server.client_connections.should eq 0
8989 server.upstream_connections.should eq 2
9090 end
@@ -103,7 +103,7 @@ describe AMQProxy::Server do
103103 server.client_connections.should eq(1 )
104104 server.upstream_connections.should eq(1 )
105105 end
106- sleep 0.1
106+ sleep 0.1 .seconds
107107 server.client_connections.should eq(0 )
108108 server.upstream_connections.should eq(1 )
109109 end
@@ -116,7 +116,7 @@ describe AMQProxy::Server do
116116 AMQP ::Client .start(proxy_url) do |conn |
117117 conn.channel
118118 end
119- sleep 2
119+ sleep 2 .seconds
120120 server.client_connections.should eq(0 )
121121 server.upstream_connections.should eq(1 )
122122 ensure
@@ -137,7 +137,7 @@ describe AMQProxy::Server do
137137 10 .times do
138138 server.client_connections.should be >= 1
139139 server.upstream_connections.should be >= 1
140- sleep 1
140+ sleep 1 .seconds
141141 end
142142 end
143143 wait_for_channel.send(5 ) # send 5
@@ -149,7 +149,7 @@ describe AMQProxy::Server do
149149 AMQP ::Client .start(proxy_url) do |conn |
150150 conn.channel
151151 wait_for_channel.send(2 ) # send 2
152- sleep 2
152+ sleep 2 .seconds
153153 end
154154 wait_for_channel.send(3 ) # send 3
155155 end
@@ -165,7 +165,7 @@ describe AMQProxy::Server do
165165 AMQP ::Client .start(proxy_url) do |conn |
166166 conn.channel
167167 wait_for_channel.send(-1 ) # send 4 (this should not happen)
168- sleep 1
168+ sleep 1 .seconds
169169 end
170170 rescue ex
171171 # ex.message.should be "Error reading socket: Connection reset by peer"
0 commit comments