From 9f1adcb2ec29d09eeed91943983274c2374e8cea Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jon=20B=C3=B6rjesson?= Date: Tue, 19 Nov 2024 13:56:18 +0100 Subject: [PATCH] Add spec --- spec/amqproxy/server_spec.cr | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/spec/amqproxy/server_spec.cr b/spec/amqproxy/server_spec.cr index c70f6a9..7ffaaac 100644 --- a/spec/amqproxy/server_spec.cr +++ b/spec/amqproxy/server_spec.cr @@ -242,4 +242,21 @@ describe AMQProxy::Server do end end end + + it "should treat all frames as heartbeats" do + with_server do |server, proxy_url| + Fiber.yield + AMQP::Client.start("#{proxy_url}?heartbeat=1") do |conn| + client = server.@clients.first?.should_not be_nil + last_heartbeat = client.@last_heartbeat + conn.channel + Fiber.yield + client.@last_heartbeat.should be > last_heartbeat + last_heartbeat = client.@last_heartbeat + conn.write AMQ::Protocol::Frame::Heartbeat.new + Fiber.yield + client.@last_heartbeat.should be > last_heartbeat + end + end + end end