add: enable read/write concurrency for ets buffer

intility · Sep 20, 2024 · 0223a68 · 0223a68
1 parent 3f504d3
commit 0223a68
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/lib/off_broadway/emqqt/broker.ex b/lib/off_broadway/emqqt/broker.ex
@@ -40,7 +40,14 @@ defmodule OffBroadway.EMQTT.Broker do
     # Create a public ETS table to act as message buffer. It needs to be public
     # because the Producer process will read directly from it to avoid copying
     # the content across processes.
-    :ets.new(state.ets_table, [:ordered_set, :named_table, :public])
+    :ets.new(state.ets_table, [
+      :ordered_set,
+      :named_table,
+      :public,
+      {:read_concurrency, true},
+      {:write_concurrency, true}
+    ])
+
     {:noreply, state, {:continue, :subscribe_to_topics}}
   end