Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
kickster97 committed Dec 12, 2024
1 parent 95be31f commit d3d6cb1
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/lavinmq/amqp/client.cr
Original file line number Diff line number Diff line change
Expand Up @@ -753,8 +753,8 @@ module LavinMQ
send_access_refused(frame, "User doesn't have read permissions to exchange '#{frame.source}'")
elsif !@user.can_write?(@vhost.name, frame.destination)
send_access_refused(frame, "User doesn't have write permissions to exchange '#{frame.destination}'")
# elsif source.is_a?(LavinMQ::MQTT::Exchange) || destination.is_a?(LavinMQ::MQTT::Exchange)
# send_access_refused(frame, "Not allowed to bind to an MQTT Exchange")
# elsif source.is_a?(LavinMQ::MQTT::Exchange) || destination.is_a?(LavinMQ::MQTT::Exchange)
# send_access_refused(frame, "Not allowed to bind to an MQTT Exchange")
else
@vhost.apply(frame)
send AMQP::Frame::Exchange::BindOk.new(frame.channel) unless frame.no_wait
Expand Down

0 comments on commit d3d6cb1

Please sign in to comment.