fix(elixir): ignore late QueueEvents task replies during close

Co-authored-by: manast <95200+manast@users.noreply.github.com>

Author: Copilot

elixir/lib/bullmq/queue_events.ex

@@ -346,6 +346,11 @@ defmodule BullMQ.QueueEvents do
     end
   end
 
+  def handle_info({ref, _result}, %{closing: true} = state) when is_reference(ref) do
+    # Ignore late replies from in-flight consumer tasks that were cancelled during close/cleanup.
+    {:noreply, state}
+  end
+
   def handle_info({:DOWN, ref, :process, _pid, reason}, %{consumer_task: ref} = state) do
     # Consumer task crashed
     Logger.error("[BullMQ.QueueEvents] Consumer task crashed: #{inspect(reason)}")

elixir/test/bullmq/queue_events_integration_test.exs

@@ -501,6 +501,30 @@ defmodule BullMQ.QueueEventsIntegrationTest do
     end
   end
 
+  # ---------------------------------------------------------------------------
+  # Close Race Conditions
+  # ---------------------------------------------------------------------------
+
+  describe "close race conditions" do
+    @tag :integration
+    @tag timeout: 10_000
+    test "ignores late consumer task replies after close", %{conn: conn, queue_name: queue_name} do
+      {:ok, events} =
+        QueueEvents.start_link(
+          queue: queue_name,
+          connection: conn,
+          prefix: @test_prefix
+        )
+
+      QueueEvents.close(events)
+
+      monitor_ref = Process.monitor(events)
+      send(events, {make_ref(), {:ok, nil}})
+
+      refute_receive {:DOWN, ^monitor_ref, :process, ^events, _reason}, 500
+    end
+  end
+
   # ---------------------------------------------------------------------------
   # Handler Module
   # ---------------------------------------------------------------------------