daniel/weewx-proxy
1
0
Fork 0
Code Issues Pull requests Activity Actions

fix: mqtt connections
All checks were successful
Build / build (push) Successful in 6m10s
Details

Browse source
This commit is contained in:
Daniel Kempkens 2024-07-15 13:23:09 +02:00
parent 1e839fd766
commit 7fba9080b4
Signed by: daniel
SSH key fingerprint: SHA256:Ks/MyhQYcPRQiwMKLAKquWCdCPe3JXlb1WttgnAoSeM
1 changed files with 13 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
lib/weewx_proxy/mqtt.ex
View file

@ -38,6 +38,19 @@ defmodule WeewxProxy.Mqtt do
password: Application.fetch_env!(:weewx_proxy, :mqtt_weewx_password), password: Application.fetch_env!(:weewx_proxy, :mqtt_weewx_password),
handler: {Tortoise311.Handler.Logger, []} 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, {Tortoise311.Connection,
[ [
name: WeewxProxy.Mqtt.ModbusIngest, name: WeewxProxy.Mqtt.ModbusIngest,