diff --git a/lib/weewx_proxy/mqtt.ex b/lib/weewx_proxy/mqtt.ex index 1868ed6..0dd73f1 100644 --- a/lib/weewx_proxy/mqtt.ex +++ b/lib/weewx_proxy/mqtt.ex @@ -38,6 +38,19 @@ defmodule WeewxProxy.Mqtt do password: Application.fetch_env!(:weewx_proxy, :mqtt_weewx_password), handler: {Tortoise311.Handler.Logger, []} ]}, + {Tortoise311.Connection, + [ + name: WeewxProxy.Mqtt.SdrIngest, + client_id: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_client_id), + server: + {Tortoise311.Transport.Tcp, + host: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_host), + port: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_port)}, + user_name: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_user), + password: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_password), + subscriptions: ["rtl433"], + handler: {WeewxProxy.Sdr.Ecowitt, []} + ]}, {Tortoise311.Connection, [ name: WeewxProxy.Mqtt.ModbusIngest,