Skip to content

Commit

Permalink
satisfy ameba
Browse files Browse the repository at this point in the history
  • Loading branch information
kickster97 committed Jan 2, 2025
1 parent 308adb6 commit 73d16ae
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion src/lavinmq/mqtt/session.cr
Original file line number Diff line number Diff line change
Expand Up @@ -157,7 +157,7 @@ module LavinMQ
)
end

def apply_policy(policy : Policy?, operator_policy : OperatorPolicy?) # ameba:disable Metrics/CyclomaticComplexity
def apply_policy(policy : Policy?, operator_policy : OperatorPolicy?)
clear_policy
Policy.merge_definitions(policy, operator_policy).each do |k, v|
@log.debug { "Applying policy #{k}: #{v}" }
Expand Down
2 changes: 1 addition & 1 deletion src/lavinmq/server.cr
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ module LavinMQ

def amqp_url
addr = @listeners
.select { |k, v| v.amqp? }
.select { |_, v| v.amqp? }
.keys
.select(TCPServer)
.first
Expand Down

0 comments on commit 73d16ae

Please sign in to comment.