Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
viktorerlingsson committed Oct 18, 2023
1 parent d013a8a commit 23b30c1
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/lavinmq/shovel/shovel.cr
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ module LavinMQ
if @queue.nil? && @exchange.nil?
raise ArgumentError.new("Shovel source requires a queue or an exchange")
end
@args = AMQ::Protocol::Table.new()
@args = AMQ::Protocol::Table.new
@consumer_args.try &.each do |k, v|
@args[k] = v
end
Expand Down Expand Up @@ -183,7 +183,7 @@ module LavinMQ
if @exchange.nil?
raise ArgumentError.new("Shovel destination requires an exchange")
end
@args = AMQ::Protocol::Table.new()
@args = AMQ::Protocol::Table.new
@consumer_args.try &.each do |k, v|
@args[k] = v
end
Expand Down

0 comments on commit 23b30c1

Please sign in to comment.