We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c9725e8 commit 9f1adcbCopy full SHA for 9f1adcb
1 file changed
spec/amqproxy/server_spec.cr
@@ -242,4 +242,21 @@ describe AMQProxy::Server do
242
end
243
244
245
+
246
+ it "should treat all frames as heartbeats" do
247
+ with_server do |server, proxy_url|
248
+ Fiber.yield
249
+ AMQP::Client.start("#{proxy_url}?heartbeat=1") do |conn|
250
+ client = server.@clients.first?.should_not be_nil
251
+ last_heartbeat = client.@last_heartbeat
252
+ conn.channel
253
254
+ client.@last_heartbeat.should be > last_heartbeat
255
256
+ conn.write AMQ::Protocol::Frame::Heartbeat.new
257
258
259
+ end
260
261
262
0 commit comments