Skip to content

Commit

Permalink
Cast to amqp connections
Browse files Browse the repository at this point in the history
  • Loading branch information
baelter committed Feb 12, 2025
1 parent 1c54143 commit f078e27
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions spec/connection_spec.cr
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ describe LavinMQ::Server do
config.channel_max = 0
with_amqp_server(config: config) do |s|
AMQP::Client::UnsafeClient.new(port: amqp_port(s), channel_max: 0).connect_unsafe
s.connections.first.channel_max.should eq 0
s.connections.first.as(LavinMQ::AMQP::Client).channel_max.should eq 0
end
end

Expand Down Expand Up @@ -131,7 +131,7 @@ describe LavinMQ::Server do
config.frame_max = 0
with_amqp_server(config: config) do |s|
AMQP::Client::UnsafeClient.new(port: amqp_port(s), frame_max: 0).connect_unsafe
s.connections.first.max_frame_size.should eq 0
s.connections.first.as(LavinMQ::AMQP::Client).max_frame_size.should eq 0
end
end

Expand Down

0 comments on commit f078e27

Please sign in to comment.