Skip to content

Commit df38d63

Browse files
authored
Merge pull request #126 from noaccOS/push-loosoqqotrrm
fix: avoid race condition with queue termination
2 parents 86fcbaf + 19bbc24 commit df38d63

1 file changed

Lines changed: 7 additions & 0 deletions

File tree

lib/astarte_vmq_plugin/vernemq_api.ex

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,5 +22,12 @@ defmodule Astarte.VMQ.Plugin.VerneMQ.API do
2222
@impl true
2323
def disconnect_by_subscriber_id(subscriber_id, opts) do
2424
:vernemq_dev_api.disconnect_by_subscriber_id(subscriber_id, opts)
25+
catch
26+
:exit, :normal -> :ok
27+
:exit, {:normal, _} -> :ok
28+
:exit, :shutdown -> :ok
29+
:exit, {:shutdown, _} -> :ok
30+
:exit, :noproc -> :ok
31+
:exit, {:noproc, _} -> :ok
2532
end
2633
end

0 commit comments

Comments
 (0)