Skip to content

Commit 233134c

Browse files
committed
[sqs] handle un-fifo-ifying a sink's queue
1 parent 6032382 commit 233134c

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

lib/sequin/consumers/sqs_sink.ex

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -54,11 +54,8 @@ defmodule Sequin.Consumers.SqsSink do
5454
end
5555

5656
defp put_is_fifo(changeset) do
57-
if changeset |> get_field(:queue_url) |> ends_with_fifo?() do
58-
put_change(changeset, :is_fifo, true)
59-
else
60-
changeset
61-
end
57+
is_fifo = changeset |> get_field(:queue_url) |> ends_with_fifo?()
58+
put_change(changeset, :is_fifo, is_fifo)
6259
end
6360

6461
defp ends_with_fifo?(nil), do: false

0 commit comments

Comments
 (0)