fix: check for reference before demonitor

intility · Oct 21, 2024 · cc3c92d · cc3c92d
1 parent 850a370
commit cc3c92d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/off_broadway/emqqt/broker.ex b/lib/off_broadway/emqqt/broker.ex
@@ -132,7 +132,7 @@ defmodule OffBroadway.EMQTT.Broker do
 
   @impl true
   def terminate(_reason, state) do
-    Process.demonitor(state.emqtt_ref)
+    if is_reference(state.emqtt_ref), do: Process.demonitor(state.emqtt_ref)
     :ets.delete(state.ets_table)
   end