diff --git a/lib/aprsme/cluster/packet_distributor.ex b/lib/aprsme/cluster/packet_distributor.ex index 82850fd..2cb3842 100644 --- a/lib/aprsme/cluster/packet_distributor.ex +++ b/lib/aprsme/cluster/packet_distributor.ex @@ -37,6 +37,12 @@ defmodule Aprsme.Cluster.PacketDistributor do :ok end + @impl true + def handle_info({:distributed_packet, _packet} = msg, state) do + handle_distributed_packet(msg) + {:noreply, state} + end + @impl true def init(_opts) do Phoenix.PubSub.subscribe(Aprsme.PubSub, @pubsub_topic)